¿Necesito sincronización adicional cuando uso un BlockingQueue?

Question

Tengo un bean simple @Entity Message.java que tiene algunas propiedades normales. El ciclo de vida de ese objeto es el siguiente

instanciación del mensaje que pasa en Tema A, que se pone en cola después en un blockingQueue

Otro hilo de una piscina obtiene ese objeto y hacer algunas cosas con él y cambia el estado del mensaje, después de eso, el objeto ingresa nuevamente en la cola bloqueante. Este paso se repite hasta que una condición lo detiene. Cada vez que el objeto obtiene lectura/escritura es potencialmente de un hilo diferente, pero con la garantía de que solo un hilo a la vez le leerá/escribirá.

Dado que las circunstancias, ¿necesito sincronizar los getters/setters? ¿Quizás las propiedades sean volátiles? o puedo simplemente irme sin sincronización?

Gracias y espero que pueda aclarar lo que estoy teniendo aquí.

Answer 1

No, no necesita sincronizar el acceso a las propiedades del objeto, o incluso usar volatile en las variables miembro.

Todas las acciones realizadas por un hilo antes de poner en cola un objeto en un BlockingQueue "suceder antes", el objeto se quita de la cola. Eso significa que cualquier cambio hecho por el primer hilo es visible para el segundo. Este es un comportamiento común para colecciones concurrentes. Consulte el último párrafo de the BlockingQueue class documentation.

Siempre que el primer hilo no realice ninguna modificación después de poner en cola el objeto, será seguro.

Answer 2

Si está seguro de que solo un hilo a la vez tendrá acceso a su objeto, entonces no necesita sincronización.

Sin embargo, puede asegurarse de que mediante el uso de la palabra clave sincronizada: cada vez que desee acceder a este objeto y asegúrese de que ningún otro hilo está utilizando la misma instancia, envuelva su código en un bloque sincronizado:

Message myMessage = // ... 
synchronized (myMessage) { 
    // You're the only one to have access to this instance, do what you want 
} 

El bloque sincronizado adquirirá un bloqueo implícito en el objeto myMessage. Entonces, ningún otro bloque sincronizado tendrá acceso a la misma instancia hasta que salga de este bloque.

Answer 3

No necesita hacer la sincronización usted mismo, porque la cola ya lo hace por usted.

La visibilidad también está garantizada.

Answer 4

Parece que podría salir de la sincronización de los métodos. El sincronizado simplemente bloquea el objeto para permitir que solo un hilo lo acceda. Ya has manejado eso con la cola de bloqueo.

Volatile sería bueno de usar, ya que eso garantizaría que cada hilo tenga la última versión, en lugar de un valor de caché local de subprocesos.