我試圖了解下面的內(nèi)容是否是線程安全的，它是由另一位開發(fā)人員編寫的，我繼承了該開發(fā)人員的代碼，但不再屬于我們。我有一個(gè) BaseProvider 類，它實(shí)際上是一個(gè)消息緩存，由 LinkedBlockingQueue 表示。此類將傳入消息存儲(chǔ)在隊(duì)列中。我有一組讀取該隊(duì)列的工作線程。因此 LinkedBlockingQueue 是線程安全的。問題 1. 當(dāng)工作線程調(diào)用provider.getNextQueuedItem()時(shí)，提供者逐項(xiàng)遍歷并將其添加到列表中并返回消息列表。在執(zhí)行此操作時(shí)，如果通過調(diào)用 addToQueue 將消息添加到提供者類中，會(huì)發(fā)生什么情況？LinkedBlockingQueue 內(nèi)部的 takeLock 是否會(huì)阻止向隊(duì)列添加新消息，直到所有消息都從隊(duì)列中取出？您會(huì)注意到，每個(gè)工作線程都可以訪問所有提供程序，因此當(dāng)一個(gè)工作線程遍歷所有提供程序并調(diào)用 getNextQueuedItem() 時(shí)，當(dāng)另一個(gè)工作線程也調(diào)用所有提供程序并調(diào)用 getNextQueuedItem() 時(shí)會(huì)發(fā)生什么？兩個(gè)工作線程會(huì)互相跨過嗎？公共抽象類 BaseProvider 實(shí)現(xiàn) IProvider { private LinkedBlockingQueue<CoreMessage> internalQueue = new LinkedBlockingQueue<CoreMessage>();@Overridepublic 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);    }}}