Нужна ли дополнительная синхронизация при использовании BlockingQueue?

Question

У меня есть простой bean @Entity Message.java, который имеет некоторые нормальные свойства. Жизненный цикл этого объекта заключается в следующем

Инстанцирование Послания происходит на тему А, который затем установлены в очередь в BlockingQueue

Другой поток из пула получает этот объект и сделать некоторые вещи с ним и изменяет состояние сообщения, после этого объект снова входит в blockingQueue. Этот шаг повторяется до тех пор, пока условие не остановится. Каждый раз, когда объект получает чтение/запись, потенциально может быть из другого потока, но с гарантией, что только один поток за раз будет читать/писать.

Учитывая, что мне нужно синхронизировать геттеры/сеттеры? Возможно, свойства нестабильны? или я могу просто уйти без синхронизации?

Спасибо и надеюсь, что смогу прояснить, что у меня здесь.

Answer 1

Нет, вам не нужно синхронизировать доступ к свойствам объекта или даже использовать volatile для переменных-членов.

Все действия, выполняемые потоком перед его очередью на объект BlockingQueue «случится раньше», объект будет удален. Это означает, что любые изменения, сделанные первым потоком, видны для второго. Это обычное поведение для одновременных коллекций. См. Последний абзац the BlockingQueue class documentation.

До тех пор, пока первый поток не будет вносить никаких изменений после очередности объекта, он будет безопасным.

Answer 2

Если вы уверены, что только один поток за один раз получит доступ к вашему объекту, вам не потребуется синхронизация.

Однако, вы можете быть уверены, что с помощью синхронизированных ключевое слово: каждый раз, когда вы хотите получить доступ к этому объекту, и быть уверенным, что никакой другой поток использует тот же экземпляр, оберните ваш код в синхронизированный блок:

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

Синхронизированный блок получит неявный замок объекта myMessage. Таким образом, ни один другой синхронизированный блок не будет иметь доступ к тому же экземпляру, пока вы не покинете этот блок.

Answer 3

Вам не нужно выполнять синхронизацию самостоятельно, потому что очередь делает это за вас уже.

Видимость также гарантирована.

Answer 4

Казалось бы, вы могли бы уйти от синхронных методов. Синхронизированный просто блокирует объект, чтобы разрешить доступ к нему только одному потоку. Вы уже справились с этой блокировкой.

Volatile будет полезен, так как это гарантирует, что каждый поток имеет самую последнюю версию, вместо значения локального кеша потока.