3

2 つのスレッドがあり、LinkedBlockingQueue で同期を正しく実行していることを確認したい..これは正しいですか? または、(messageToCommsQueue) での明示的な同期は必要ありませんか?

宣言：

    private LinkedBlockingQueue<BaseMessage> messagesToCommsQueue;

方法 1:

private void startOperationModeStatusMessageExecutor() {

    ScheduledExecutorService operationModeStatusExecutor = Executors.newSingleThreadScheduledExecutor();
    operationModeStatusExecutor.scheduleAtFixedRate((new Runnable() {

        @Override
        public void run() {
            ModeStatusMessage commsOperateMsg;
                commsOperateMsg = MessageFactory.getModeStatusMessage(status.ordinal());
            synchronized (messagesToCommsQueue) {
                messagesToCommsQueue.add(commsOperateMsg);
            }
        }

    }), 0, 10, TimeUnit.SECONDS);
}

方法 2:

    Executor commsSenderExecutor = Executors.newSingleThreadExecutor();
    commsSenderExecutor.execute(new Runnable() {

        @Override
        public void run() {
            while (getStatus().equals(ModeStatus.INITIATE) || getStatus().equals(ModeStatus.OPERATE)) {
                BaseMessage m = null;
                try {
                    synchronized (messagesToCommsQueue) {
                        m = messagesToCommsQueue.take();
                    }
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }



            }
        }

    });
4

1 に答える 1

4

はい、必要ありません。JavaDocは次のように述べています。

BlockingQueue の実装はスレッドセーフです。

于 2010-02-21T22:30:44.733 に答える