JDK并发包

ゞ浴缸里的玫瑰 2022-01-05 09:59 160阅读 0赞

# JDK并发包 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70]

## 各种同步控制工具的使用 ##

ReenterLock:相对于synchronize,具有可重入、可中断、可限时、公平锁等功能；

ReenterLock lock=new ReenterLock();//声明锁
    Thread thread=new Thread(lock);//使用锁
    Thread thread1=new Thread(lock);//使用锁 但此时只允许一个线程进入临界区

Condition :类似于Object.wait()和Object.notify() 与ReenterLock结合使用。

await() //类似于wait()
    signal()//类似于notify()
    ReenterLock lock=new ReenterLock();//声明锁
    Condition condition=lock.newCondition();//绑定Condition

Semaphore:信号量，类似于共享锁，允许多个同时进入临界区

static final Semaphore semp =new Semaphore(5);//声明信号量
    #在run方法中
    semp.acquire();//获取信号量 默认获取一个 只有在有信号量的情况下才能正常进行
    semp.release();//释放信号量

ReadWriteLock:读写锁，只对写操作进行加锁，一定程度实现高并发  
读读不堵塞、不互斥；读写互斥；写写阻塞

ReentrantReadWriteLock readWriteLock =new ReentrantReadWriteLock();
    Lock readLock=readWriteLock.read
    Lock writeLock=readWriteLock.readLock();//对读操作加锁
    Lock writeLock=readWriteLock.writeLock();//对写操作加锁

CountDownLatch：倒数计时器 ，用于对主线中，提供检查任务线程（一个线程等待多个线程）

static final CountDownLatch end =new CountDownLatch(10);//定义定时器 10个检测任务线程
    end.countDown();//开始检查任务 检测任务减一
    end.await();//等待检查任务全部完成

CyclicBarrier：循环栅栏，是一个可以反复使用地计数器（多个线程相互等待）  
只要在所有的任务都在栅栏上，才开始线程

//4个线程 4个线程集合完毕后，执行主线程事件
    CyclicBarrier cyclic =new CyclicBarrier(4,new Thread());
    
    User user = new User(cyclic);//使用栅栏 这里只能使用4次
    Thread thread=new Tread(user);//这种方式类似继承了Runnable接口
    thread.start(); //会调用其run()方法
    #定义在run方法体中
    cyclic.await(); //等待所有线程执行run()  第一次执行new Thread()
    dowork();//让线程中执行某种任务
    cyclic.await();//等待所有线程执行dowork() 第二次执行new Thread()

LockSupport：实现线程阻塞和去除线程阻塞状态  
阻塞状态下：线程会放弃对CPU的使用权

LockSupport.park() 在run方法体中使用park挂起线程
    LockSupport.unpark(Thread a) 给线程运行许可 当先执行unpark时，park是无效的

ReentrantLock ：重入锁  
场景：在尝试获取资源失败后，进入一个等待队列，等待重新被授权  
基本原理：CAS、等待队列、park

## 并发容器 ##

集合包装：HashMap、List、Set  
![在这里插入图片描述][20190623181959634.png]  
并发集合:ConcurrentHashMap、ConcurrentLinkedQueue。  
阻塞队列:BlockingQueue

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70]: /images/20211229/22e855e07f364e1f8149ea8bef111f8c.png
[20190623181959634.png]: /images/20211229/ac68b4451c164516ae3696d7970493ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]: /images/20211229/5b0584c4b681456d8097c7215f379a6d.png