集合类的发展历程 
? 早期集合类Vector、Hashtable:线程安全的。是怎么保证线程安排的,使用synchronized修饰方法  ? 为了提高性能,使用ArrayList、HashMap替换,线程不安全,但是性能好。使用ArrayList、HashMap,需要线程安全怎么办呢?使用Collections.synchronizedList(list)、Collections.synchronizedMap(m)解决,底层使用synchronized代码块锁。  虽然也是锁住了所有的代码,但是锁在方法里边,并所在方法外边性能可以理解为稍有提高吧。毕竟进方法本身就要分配资源的  ? 在大量并发情况下如何提高集合的效率和安全呢?  提供了新的线程同步集合类,位于java.util.concurrent包下,使用Lock锁或者volatile+CAS的无锁化。  ConcurrentHashMap  CopyOnWriteArrayList   CopyOnWriteArraySet  
新一代并发集合类 
ConcurrentHashMap 
ConcurrentHashMap是并发效率更高的Map,用来替换其他线程安全的Map容器,比如Hashtable和Collections.synchronizedMap。实际上,并发执行时,线程安全的容器只能保证自身的数据不被破坏,但无法保证业务的行为是否正确。错误的理解这里的线程安全,不恰当的使用ConcurrentHashMap,往往会导致出现问题  
public static void main(String[] args) {
        final Map<String, AtomicInteger> count = new ConcurrentHashMap<>();
        final CountDownLatch endLatch = new CountDownLatch(2);
        Runnable task = new Runnable() {
            @Override
            public void run() {
                AtomicInteger oldValue;
                for (int i = 0; i < 5; i++) {
                    oldValue = count.get("a");
                    if (null == oldValue) {
                        AtomicInteger zeroValue = new AtomicInteger(0);
                        oldValue = count.putIfAbsent("a", zeroValue);
                        if (null == oldValue) {
                            oldValue = zeroValue;
                        }
                    }
                    oldValue.incrementAndGet();
                }
                endLatch.countDown();
            }
        };
        new Thread(task).start();
        new Thread(task).start();
        try {
            endLatch.await();
            System.out.println(count);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
  
为什么ConcurrentHashMap不允许插入null值? https://juejin.cn/post/7057696800739688479  HashMap与ConcurrentHashMap面试要点https://juejin.cn/post/7097147987058491423  
CopyOnWriteArrayList 
先简单说一说Java中的CopyOnWriteArrayListhttps://juejin.cn/post/6844903576339218440  
public class IteratorTest {
    private static CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();
    public static void main(String[] args) {
        list.add("1");
        list.add("2");
        list.add("3");
        Iterator<String> iter = list.iterator();
        
        ExecutorService service = Executors.newFixedThreadPool(10);
        
        for (int i = 0; i < 10; i++) {
            service.execute(new Runnable() {
                @Override
                public void run() {
                    while (iter.hasNext()) {
                        System.err.println(iter.next());
                    }
                }
            });
        }
        
        for (int i = 0; i < 10; i++) {
            service.execute(new Runnable() {
                @Override
                public void run() {
                    list.add("121");
                }
            });
        }
        System.err.println(Arrays.toString(list.toArray()));
    }
}
  
CopyOnWriteArrayList 你了解多少?https://segmentfault.com/a/1190000021789020  
CopyOnWriteArraySet 
面试官:Java 有线程安全的 set 吗?我竟然答不上来 https://segmentfault.com/a/1190000040871613 
                
                
                
        
        
    
  
 
 |