示例代碼

package com.example.demo.service;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class UnSafeCDTest {ExecutorService executorService = Executors.newFixedThreadPool(5);public static void main(String[] args) throws InterruptedException {for(int i = 0; i < 20; i++){UnSafeCDTest unSafeCDTest = new UnSafeCDTest();unSafeCDTest.test();}}public void test() throws InterruptedException {List<String> list = new ArrayList<>();//  List<String> list = new CopyOnWriteArrayList<>();CountDownLatch countDownLatch = new CountDownLatch(5);for (int i = 0; i < 5; i++) {executorService.submit(() -> {// TODOlist.add("1" );// TODO// cdcountDownLatch.countDown();});}countDownLatch.await();System.out.println( list.size());}
}

輸出結果

可以看到有一個結果為4；
修改ArrayList為線程安全的List,CopyOnWriteArrayList;
驗證結果

CopyOnWriteArrayList為什么是線程安全的
查看源碼可以看到通過了加鎖實現了線程安全

/*** Appends the specified element to the end of this list.** @param e element to be appended to this list* @return {@code true} (as specified by {@link Collection#add})*/public boolean add(E e) {final ReentrantLock lock = this.lock;lock.lock();try {Object[] elements = getArray();int len = elements.length;Object[] newElements = Arrays.copyOf(elements, len + 1);newElements[len] = e;setArray(newElements);return true;} finally {lock.unlock();}}