ArrayList->Vector,Stack

HashMap->HashTable(key,value不能為null)

Collections.synchronizedXXX（List、Set、Map）

[java]  view plain  copy

1. import com.mmall.concurrency.annoations.ThreadSafe;  
2. import lombok.extern.slf4j.Slf4j;  
3.   
4. import java.util.List;  
5. import java.util.Vector;  
6. import java.util.concurrent.CountDownLatch;  
7. import java.util.concurrent.ExecutorService;  
8. import java.util.concurrent.Executors;  
9. import
    java.util.concurrent.Semaphore;  
10.   
11. @Slf4j  
12. @ThreadSafe  
13. public class VectorExample1 {  
14.     // 請求總數  
15.     public static int clientTotal = 
    5000;  
16.     // 同時併發執行的執行緒數  
17.     public static int threadTotal = 200;  
18.     private static List<Integer> list = new Vector<>();  
19.     public static void main(String[] args) throws Exception {  
20.         ExecutorService executorService = Executors.newCachedThreadPool();  
21.         final Semaphore semaphore = new Semaphore(threadTotal);  
22.         final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);  
23.         for (int i = 0; i < clientTotal; i++) {  
24.             final int count = i;  
25.             executorService.execute(() -> {  
26.                 try {  
27.                     semaphore.acquire();  
28.                     update(count);  
29.                     semaphore.release();  
30.                 } catch (Exception e) {  
31.                     log.error("exception", e);  
32.                 }  
33.                 countDownLatch.countDown();  
34.             });  
35.         }  
36.         countDownLatch.await();  
37.         executorService.shutdown();  
38.         log.info("size:{}", list.size());  
39.     }  
40.   
41.     private static void update(int i) {  
42.         list.add(i);  
43.     }  
44. }  

同步容器不一定是執行緒安全的，例如：

[java]  view plain  copy

1. import com.mmall.concurrency.annoations.NotThreadSafe;  
2.   
3. import java.util.Vector;  
4.   
5. @NotThreadSafe  
6. public class VectorExample2 {  
7.     private static Vector<Integer> vector = new Vector<>();  
8.     public static void main(String[] args) {  
9.         while (true) {  
10.             for (int i = 0; i < 10; i++) {  
11.                 vector.add(i);  
12.             }  
13.             Thread thread1 = new Thread() {  
14.                 public void run() {  
15.                     for (int i = 0; i < vector.size(); i++) {  
16.                         vector.remove(i);  
17.                     }  
18.                 }  
19.             };  
20.             Thread thread2 = new Thread() {  
21.                 public void run() {  
22.                     for (int i = 0; i < vector.size(); i++) {  
23.                         vector.get(i);  
24.                     }  
25.                 }  
26.             };  
27.             thread1.start();  
28.             thread2.start();  
29.         }  
30.     }  
31. }  

[java]  view plain  copy

1. import java.util.Iterator;  
2. import java.util.Vector;  
3.   
4. public class VectorExample3 {  
5.     // java.util.ConcurrentModificationException  
6.     private static void test1(Vector<Integer> v1) { // foreach  
7.         for(Integer i : v1) {  
8.             if (i.equals(3)) {  
9.                 v1.remove(i);  
10.             }  
11.         }  
12.     }  
13.   
14.     // java.util.ConcurrentModificationException  
15.     private static void test2(Vector<Integer> v1) { // iterator  
16.         Iterator<Integer> iterator = v1.iterator();  
17.         while (iterator.hasNext()) {  
18.             Integer i = iterator.next();  
19.             if (i.equals(3)) {  
20.                 v1.remove(i);  
21.             }  
22.         }  
23.     }  
24.   
25.     // success  
26.     private static void test3(Vector<Integer> v1) { // for  
27.         for (int i = 0; i < v1.size(); i++) {  
28.             if (v1.get(i).equals(3)) {  
29.                 v1.remove(i);  
30.             }  
31.         }  
32.     }  
33.   
34.     public static void main(String[] args) {  
35.         Vector<Integer> vector = new Vector<>();  
36.         vector.add(1);  
37.         vector.add(2);  
38.         vector.add(3);  
39.         test1(vector);  
40.     }  
41. }  

HashTable 執行緒安全

[java] 

相關推薦