Нужна ли явная синхронизация?
У меня есть два потока, и я хочу убедиться, что я правильно выполняю синхронизацию в LinkedBlockingQueue .. Это правильно? Или явная синхронизация на (messageToCommsQueue) не нужна?
Декларация:
private LinkedBlockingQueue<BaseMessage> messagesToCommsQueue;
Способ первый:
private void startOperationModeStatusMessageExecutor() {
ScheduledExecutorService operationModeStatusExecutor = Executors.newSingleThreadScheduledExecutor();
operationModeStatusExecutor.scheduleAtFixedRate((new Runnable() {
@Override
public void run() {
MT02OperationModeStatusMessage commsOperateMsg;
commsOperateMsg = MessageFactory.getMT1102OperationModeStatusMessage(status.ordinal());
synchronized (messagesToCommsQueue) {
messagesToCommsQueue.add(commsOperateMsg);
}
}
}), 0, 10, TimeUnit.SECONDS);
}
Способ второй:
Executor commsSenderExecutor = Executors.newSingleThreadExecutor();
commsSenderExecutor.execute(new Runnable() {
@Override
public void run() {
while (getStatus().equals(OperationModeStatus.INITIATE) || getStatus().equals(OperationModeStatus.OPERATE)) {
BaseMessage m = null;
try {
synchronized (messagesToCommsQueue) {
m = messagesToCommsQueue.take();
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
});