Java并发集合

List，Set，Map在遍历过程中是不允许更新操作的（增，删，该）；

非阻塞式集合（Non-Blocking Collection）  ConcurrentLinkedDeque：

　　这类集合包括添加和移除数据的方法。如果方法不能立即被执行，则返回null或抛出异常，但是调用这个方法的线程不会被阻塞。

阻塞式集合（Blocking Collection） LinkedBlockingDeque：

　　阻塞式集合（Blocking Collection）：这类集合包括添加和移除数据的方法。当集合已满或为空时，被调用的添加或者移除方法就不能立即被执行，那么调用这个方法的线程将被阻塞，一直到该方法可以被成功执行。

非阻塞式集合类的使用示例：

/**
 * 非阻塞式并发集合
 * 添加大量的数据到一个列表中；
 * 从同一个列表中移除大量的数据。
 * @author Administrator
 *
 */
public class CollectionDemo01 {

    public static void main(String[] args) throws Exception {
        //使用多线程环境下非阻塞的集合类
        ConcurrentLinkedDeque<String> list = new ConcurrentLinkedDeque<>();

        //添加数据
        Thread[] add = new Thread[100];
        for (int i = 0; i < add.length; i++) {
            add[i] = new Thread(()->{
                for (int j = 0; j < 10000; j++) {
                    list.add(Thread.currentThread().getName()+":Element "+j);
                }
            });
            add[i].start();
            add[i].join();
        }
        System.out.println("after add size"+list.size());
        //移除数据
        Thread[] poll = new Thread[100];
        for (int i = 0; i < poll.length; i++) {
            poll[i] = new Thread(()->{
                for (int j = 0; j < 5000; j++) {
                    //移除尾部
                    list.pollLast();
                    //移除头部
                    list.pollFirst();
                }
            });
            poll[i].start();
            poll[i].join();
        }
        System.out.println("after poll size:"+list.size());
    }

}

阻塞式集合类的使用示例：

/**
 * 阻塞式并发集合
 * @author Administrator
 *
 */
public class CollectionDemo02 {

    public static void main(String[] args) {
        //使用多线程下的阻塞式并发集合类
        LinkedBlockingDeque<String> list = new LinkedBlockingDeque<>(5);
        //添加数据
        Thread thread = new Thread(()->{
            for (int i = 0; i < 3; i++) {
                for (int j = 0; j < 5; j++) {
                    String str = new String(i+":"+j);
                    try {
                        list.put(str.toString());
                        System.out.println("client:"+str+(new Date()));
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        });
        thread.start();

        //取数据
        for (int i = 0; i < 5; i++) {
            for (int j = 0; j < 3; j++) {
                try {
                    System.out.println("main:before take size:"+list.size());
                    //从集合中取出数据
                    String str = list.take();
                    System.out.println("main:after take"+str+" size:"+list.size());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                try {
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        System.out.println("end=========");
    }
}