java.util.concurrent包提供了大量的并发工具。
大家好，我是李福春，今天的题目是：
java提供的并发工具有哪些？
答：java.util.concurrent工具包中提供的工具分4大类。
一， 同步工具，CountDownLatch, CyclicBarrier , Semaphore ;
二， 并发安全容器， ConcurrentHashMap,ConcurrentSkipListMap,
CopyOnWriteArrayList,CopyOnWriteArraySet;
三，并发安全队列，主要用在线程池上，ArrayBlockingQueue,SynchronousQueue,PriorityBlockingQueue；
四，并发线程池executor框架；
同步工具
semaphore
信号量，设置并发访问的线程数量。
一般要结对使用： try{s.acquire();}finally{s.release()}
package org.example.mianshi.synctool;
import java.util.concurrent.Semaphore;
/**
* 创建日期: 2020/3/30 14:24
* 描述:
信号量应用
*
* @author lifuchun
*/
public class SemaphoreApp {
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(0);
for (int i = 1; i <= 10; i++) {
new MyThread(semaphore).start();
}
System.out.println("go ```");
semaphore.release(5);
}
public static class MyThread extends Thread {
private Semaphore semaphore;
public MyThread(Semaphore semaphore) {
this.semaphore = semaphore;
}
@Override
public void run() {
try {
semaphore.acquire();
System.out.println(System.currentTimeMillis() + " :" + Thread.currentThread().getName() + " -execute ```");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
semaphore.release();
}
}
}
}
CountDownLatch
设置线程等待某些操作完成；
其它线程完成了，调用 c.countDown（）
当c的value=0，即执行 其它线程在 await（）方法后面逻辑。
package org.example.mianshi.synctool;
import java.util.concurrent.CountDownLatch;
import java.util.stream.IntStream;
/**
* 创建日期: 2020/3/30 14:38
* 描述:
countDownLatch的例子
* @author lifuchun
*/
public class CountDownLatchApp {
public static void main(String[] args) {
CountDownLatch countDownLatch = new CountDownLatch(5);
new Thread(() -> {
try {
countDownLatch.await();
System.out.println("后置任务");
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
IntStream.rangeClosed(1, 10)
.forEach(i -> new MyThread(countDownLatch).start());
}
public static class MyThread extends Thread {
private CountDownLatch countDownLatch;
public MyThread(CountDownLatch countDownLatch) {
this.countDownLatch = countDownLatch;
}
@Override
public void run() {
countDownLatch.countDown();
System.out.println("前置任务");
}
}
}
CyclicBarrier
允许多个线程同时到达某个屏障。 设置并发执行的线程数量。
一般调用await()方法，当数量达到预设的数量N,则统一执行await（）方法后面的逻辑，会自动重置。
package org.example.mianshi.synctool;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.stream.IntStream;
/**
* 创建日期: 2020/3/30 14:49
* 描述:
cyclicBarrier的应用
*
* @author lifuchun
*/
public class CyclicBarrierApp {
public static void main(String[] args) {
CyclicBarrier cyclicBarrier = new CyclicBarrier(3, CyclicBarrierApp::run);
IntStream.rangeClosed(1, 30)
.forEach(i -> new MyThread(cyclicBarrier).start());
}
private static void run() {
System.out.println("reset , start again !");
}
public static class MyThread extends Thread {
private CyclicBarrier cyclicBarrier;
public MyThread(CyclicBarrier cyclicBarrier) {
this.cyclicBarrier = cyclicBarrier;
}
@Override
public void run() {
try {
cyclicBarrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println("do my work!");
}
}
}
同步安全容器
类层级如下图：
场景选择：
1， 如果注重的是并发放入和获取的速度，使用ConcurrentHashMap ;
2, 如果注重顺序，并且频繁并发修改大量的数据，使用ConcurrentSkipListMap
CopyOnWrite*防御复制：
add,set,remote操作都会copy原数组，修改完成之后替换原来的数组，代价比较大，适合读多写少的场景；
小结
