同步辅助类 线程池 并发集合类 都是在线程同步的基础上增加了一些同步的东西,在线程同步的基础上更好的实现线程同步.实现的效率更高,更方便而已.
多线程并不是很难 需要你把代码写出来...然后分析运行的效果.
软件包 java.util.concurrent JDK1.5之后才出现的. 同步辅助类提供了更优秀的解决方案.
同步器
四个类可协助实现常见的专用同步语句。
Semaphore 是一个经典的并发工具。
CountDownLatch 是一个极其简单但又极其常用的实用工具,用于在保持给定数目的信号、事件或条件前阻塞执行。
CyclicBarrier 是一个可重置的多路同步点,在某些并行编程风格中很有用。
Exchanger 允许两个线程在 collection 点交换对象,它在多流水线设计中是有用的。
类 Semaphore
一个计数信号量。从概念上讲,信号量维护了一个许可集。
Semaphore中维护了一个可许集,这个可许集的体现就是构造方法中传入一个int值
final Semaphore semaphore = new Semaphore(5);
信号量:Semaphore。
允许临界区(共享内容)内存在固定个数的线程,并发访问。
如果信号量为1.成为二进制信号量,和同步(synchronized) 效果一样。
场景:
一个混沌摊,一开始只有一个桌子,一张桌子同时只能被一个人使用,只有拿到许可之后才可以使用这个桌子. 后来有了5个桌子,最多能允许5个拿到许可的人同时访问.
1 import java.util.Random; 2 import java.util.concurrent.Semaphore; 3 import java.util.concurrent.TimeUnit; 4 5 public class SemaphoreDemo { 6 7 public static void main(String[] args) { 8 final Semaphore semaphore = new Semaphore(5); 9 //Semaphore中维护了一个可许集,这个可许集的体现就是构造方法中传入一个int值10 //有5个许可,同时允许5个线程同时来拿11 12 for (int i = 0; i < 50; i++) {13 14 new Thread(new Runnable() {15 16 @Override17 public void run() {18 try {19 semaphore.acquire();//获得一个许可,从5减去1,有许可的才让访问20 } catch (InterruptedException e1) {21 e1.printStackTrace();22 }23 System.out.println(Thread.currentThread().getName()24 + " :来了,现在有 "+(5-semaphore.availablePermits())+" 名顾客");//有几名顾客就意味着有多少个并发.25 26 try {27 TimeUnit.SECONDS.sleep(new Random().nextInt(3));28 } catch (InterruptedException e) {29 e.printStackTrace();30 }31 32 System.out.println("-->" + Thread.currentThread().getName()33 + " :走了");34 35 semaphore.release();//释放许可36 }37 }).start();38 39 }40 }41 }