如何通過多線程成功訪問和循環ArrayList？

Question

我需要ArrayList中的幫助。 我有一個字符串arraylist。我正在循環訪問這個列表並將它們一個接一個地發送到輸出流。 當我在列表中循環併發送它們時，另一個線程可能會向它添加一些元素。發送一個元素後，它也必須從列表中刪除。

我該如何做到這一點？

Answer 1

如果項目被添加到列表的末尾，您最好使用Queue來代替。 Java5及以上版本提供了多種線程安全實現，包括ConcurrentLinkedQueue和LinkedBlockingQueue。

一般來說，前者是最好的選擇，除非你想要一個有界的阻塞隊列，在這種情況下使用後者。

Answer 2

爲作業使用正確的數據結構。使用ConcurrentLinkedQueue。以下是它在javadoc中的描述：

基於鏈接節點的無限線程安全queue。該隊列命令元素FIFO（先進先出）。隊列中的頭是已在隊列上最長時間的元素。隊列中的尾部是已經在隊列上的最短時間的元素。新元素插入到隊列尾部，隊列檢索操作獲取隊列頭部的元素。 當許多線程共享對一個通用集合的訪問時，A ConcurrentLinkedQueue是一個合適的選擇。

Answer 3

假設這是作業，我會給出一些提示。

• 兩個線程可以synchronize名單上保留獨佔訪問
• 的remove()方法返回的對象中刪除
• 您可以從列表的開始同時加入到結束

刪除這應該可以幫助你，如果你發佈了迄今爲止的所有內容，那麼我們可以根據你的代碼提供建議。

Answer 4

我建議使用的BlockingQueue的一些執行情況的ArrayList是不適合併發修改：

class Producer implements Runnable { 

    private BlockingQueue<String> queue; 

    public Producer(BlockingQueue<String> queue) { 
    this.queue = queue; 
    } 

    public void run() { 
    try { 
     queue.put("foo"); 
     queue.put("done"); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    } 
} 

class Consumer implements Runnable { 

    private final BlockingQueue<String> queue; 

    public Consumer (BlockingQueue<String> queue) { 
    this.queue = queue; 
    } 

    public void run() { 
    try { 
     String value = queue.take(); 
     while (!value.equals("done")) { 
     value = queue.take(); 
     System.out.println(value); 
     } 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    } 
} 

public class Main { 
    public static void main(String[] args) throws Exception { 
    BlockingQueue<String> queue = new LinkedBlockingQueue<String>(); 
    Thread producer = new Thread(new Producer(queue)); 
    Thread consumer = new Thread(new Consumer(queue)); 
    producer.start(); 
    consumer.start(); 
    producer.join(); 
    consumer.join(); 
    } 
}