Java线程---并发集合

List

• CopyOnWriteArrayList

  • 并发修改时保证线程安全

    • 通过ReentrantLock实现多个线程并发修改时的线程安全同步（添加元素的同时，不允许删除）

    • 添加新元素：list.add("")

    • 按照指定下标替换元素：list.set(index, element)

    • 按照指定下标删除元素：list.remove(0)

  • 并发读取

    • 没有加锁，允许多个线程同时并发读取；但是读取时，可能产生脏读（读取的同时，允许写入操作）。

  • CopyOnWrite思想：修改时将原数组内容复制Copy到新数组内，在新数组内修改，然后替换

Set

• CopyOnWriteArraySet

  • 内部通过一个CopyOnWriteArrayList实现

Queue

• BlockingQueue阻塞队列

  • 阻塞队列：由两个线程，分别进行读写（task和put）操作；读取时，不允许写入，如果队列为空，则读取线程阻塞；写入时，不允许读取，如果队列已满，则写入线程阻塞；

• ArrayBlockingQueue

  • 有界队列

• LinkedBlockingQueue

  • 无界队列

 public class Test02 {public static void main(String[] args) {//自增idAtomicInteger number = new AtomicInteger();//保存生产者的阻塞队列LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>();//创建线程池ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(6,6,0, TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>());​​//创建1个生产者者线程poolExecutor.execute(()->{//产生10个数据for(int i = 1;i <=10;i++){String data = "数据"+number.getAndIncrement();System.out.println("[生产者]生成："+data);​try {//保存至阻塞队列queue.put(data);//模拟延时Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}​​});//创建5个消费者线程for(int i= 1; i <= 5; i++){poolExecutor.execute(()->{while(true){try {String data = queue.take();System.out.println("消费者=="+Thread.currentThread().getName()+"获取："+data);} catch (InterruptedException e) {e.printStackTrace();}}});}}}

Map

• ConcurrentHashMap

  • JDK1,7

    • 通过分段锁实现线程安全

  • JDK1,8

    • 通过 synchronized+CAS实现线程安全

      • 当产生哈希冲突时，通过synchronized将根节点作为锁，进行线程的同步安全

      • 在没有产生哈希冲突时，通过CAS进行无锁化操作，降低synchronized进行线程同步操作所引发的性能下降