为什么我能够同时读/写arraylist？

Question

我在这里使用多个线程 .. 一个线程正在获取列表，另一个正在向列表添加名称，这两个线程都在使用共享资源，即 ArrayList object 它应该给 concurrentModification 类似的东西没有给出，或者我无法在我的代码中正确使用线程

代码如下：

import java.util.*;
import java.util.logging.Level;
import java.util.logging.Logger;

public class threadprac  
 {
  public static void main(String args[]){

        ArrayList<String> shared;
         shared = new ArrayList<>(); 
         String[] arr=new String[]{"amol","robin","shanu","saaru","mohit"};
         for(String n:arr)
           shared.add(n);  
         Thread tf = new Thread(new fetch(shared));
         Thread tm = new Thread(new manipulate(shared));
         tm.setName("thread-M"); tf.setName("thread-F");
         tf.start();
         tm.start();
         try {
         Thread.currentThread().sleep(2000); 
    } catch (InterruptedException ex) {
        Logger.getLogger(threadprac.class.getName()).log(Level.SEVERE, null, ex);
    }
         for(String n:shared)
           System.out.print(n+" ");  

 }    
}

class fetch implements Runnable
{
 ArrayList<String> f;
 fetch(ArrayList shared){
   this.f=shared;
   }
 @Override
 public void run(){
  displayList(); 
  }
void displayList(){
   Iterator<String> itr=f.iterator();
   while(itr.hasNext()){
      String name = itr.next();
      System.out.print(name+" ");
   }
   System.out.println();
  } 
}

class manipulate implements Runnable
{
ArrayList<String> m;
manipulate(ArrayList shared){
    this.m=shared;
}
@Override
public void run(){
    addName();
 }
void addName(){
  m.add("rohit"); 
 } 
}

Answer 1

Thread.start() 需要一些时间。第一个线程很可能在第二个线程开始使用它的迭代器之前已经完成——反之亦然，无法预测哪个线程。

并发的一个问题是我们必须使用“非常可能”这样的短语，因为我们无法预测事情发生的顺序，因此某些程序的行为会变得不一致。

尝试将一些 Thread.sleep() 语句放入循环中，这样您就可以更加确定 ArrayList get()s 在 Iterator 打开时执行。

请注意，虽然添加休眠是一种快速简便的方法，可以将时间“调整”到足够长的时间段，以便您可以目睹某些情况的发生，但它们几乎不是解决实际代码中线程同步问题的正确方法。

Answer 2

两个线程中的每一个都只花费很少的时间（在现代 CPU 上可能不到 1 微秒），以至于它们同时执行的机会非常低。您必须在两个线程中做大量工作以确保它们同时处于活动状态。

Answer 3

正如@Slim 提到的，由于显示和添加时线程的延迟。 修改代码如下，添加 Sleep，会导致 concurrentModificationException。

void displayList() throws InterruptedException {
        Iterator<String> itr = f.iterator();
        while (itr.hasNext()) {
            String name = itr.next();
            Thread.sleep(100);
            System.out.print(name + " ");
        }
        System.out.println();
    }

 ...

    void addName() throws InterruptedException {
    Thread.sleep(100);
    m.add("rohit");
}

例外：

amol Exception in thread "thread-F" java.util.ConcurrentModificationException
    at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:901)
    at java.util.ArrayList$Itr.next(ArrayList.java:851)
    at fetch.displayList(TestClass.java:43)
    at fetch.run(TestClass.java:33)
    at java.lang.Thread.run(Thread.java:745)

Answer 4

ArrayList 不是线程安全的。您可能应该查看类似 ConcurrentLinkedDeque

的内容