LinkedBlockingQueue和工作线程-此代码线程安全吗？

Question

我试图理解如果下面是线程安全的，它是由另一个开发人员编写的代码，我已经继承和不再与我们在一起。

我有一个BaseProvider类，它实际上是一个消息缓存，由LinkedBlockingQueue表示。该类将传入的消息存储在队列中。

我有一组读此队列的辅助线程。因此，LinkedBlockingQueue是线程安全的。

正如您所注意到的，每个辅助线程都可以访问所有的提供者，所以当一个辅助线程遍历所有提供者并调用getNextQueuedItem（）时，当另一个辅助线程也遍历所有提供者并调用getNextQueuedItem（）时会发生什么呢？两个工作线程会互相跨过吗？

公共抽象类BaseProvider实现IProvider{

 private LinkedBlockingQueue<CoreMessage> internalQueue = new LinkedBlockingQueue<CoreMessage>();

@Override
public synchronized List<CoreMessage> getNextQueuedItem() {
    List<CoreMessage> arrMessages = new ArrayList<CoreMessage>();                    
    if (internalQueue.size() > 0) {
        Logger.debug("Queue has entries");    
        CoreMessage msg = null;
        try {
            msg = internalQueue.take();
        } catch (InterruptedException e) {
            Logger.warn("Interruption");
            e.printStackTrace();
        }
        if (msg != null) {
            arrMessages.add(msg);
        }
    }
    return arrMessages;
}

protected synchronized void addToQueue(CoreMessage message) {
    try {
        internalQueue.put(message);
    } catch (InterruptedException e) {
        Logger.error("Exception adding message to queue " + message);
    }
}

}

public class Worker implements Runnable 
 @Override
 public void run() {
    Logger.info("Worker - Running Thread : " + Thread.currentThread().getName());

    while (!stopRequested) {
        boolean processedMessage = false;
        for (IProvider provider : providers) {
            List<CoreMessage> messages = provider.getNextQueuedItem();
            if (messages == null || messages.size() != 0) {
                processedMessage = true;
                for (CoreMessage message : messages) {
                    final Message msg = createEndurMessage(provider, message);
                    processMessage(msg);
                    message.commit();
                }
            }
        }
        if (!(processedMessage || stopRequested)) {
            // this is to stop the thread from spinning when there are no messages
            try {
                Thread.sleep(WAIT_INTERVAL);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

}

Answer 1

如果通过调用AddToQueue向provider类添加了消息，会发生什么？

GetNextQueuedItem()和AddToQueue(...)都是Synchronized方法。如果这是访问private...internalqueue的仅有的两个方法，那么多个线程就无法同时访问internalqueue。

当一个工作线程遍历所有提供者并调用getNextQueuedItem（）时，当另一个工作线程也遍历所有提供者并调用getNextQueuedItem（）时会发生什么？

是否询问多个员工访问同一提供商的情况？这不可能发生，因为getNextQueuedItem()是synchronized方法。

--或者--

您是否询问不同员工访问不同提供商的情况？这应该无关紧要（至少就baseProvider类而言），因为似乎没有任何方式可以将不同的对象相互连接。