Java 阻塞队列.Java并发工具类
2017-08-03 00:00
309 查看
摘要: Java 阻塞队列
一:阻塞队列(BlockingQueue):是一个支持两个附加操作的队列;
(1)支持阻塞的插入方法:当队列满时,队列会阻塞插入元素的线程,直到队列不满;
(2)支持阻塞的移除方法:当队列为空时,获取元素的线程会等待队列变为非空;
二:Java并发工具类:
包含CountDownLatch,CyclicBarrier,Semaphore;
(1)CountDownLatch:
允许一个线程或者多个线程等待其他线程完成操作;他主要是使用了线程的join();Thread.join()会一直去检测使用join的线程是否isAlive();如果isAlive(),就wait();
(2)CyclicBarrier:可循环使用的屏障;
让一组线程到达一个屏障(也叫同步点)时被阻塞,知道最后一个线程到达屏障时,屏障才会开门,所有被拦截的线程才开始继续执行。
默认的构造方法:Cyclebarrier c = Cyclebarrier(int num);num表示拦截线程的数量,每个线程调用await()方法告诉CycleBarrier我已经到达了屏障,然后当前线程被阻塞。
(3)Semaphore(信号量):
用来控制同时访问特定资源的线程数量,他通过协调各个线程,以保证合理的使用公共资源;比如数据库链接,30个线程,但是只有10个能同时进行;acquire获取进行许可证,release()释放;
一:阻塞队列(BlockingQueue):是一个支持两个附加操作的队列;
(1)支持阻塞的插入方法:当队列满时,队列会阻塞插入元素的线程,直到队列不满;
(2)支持阻塞的移除方法:当队列为空时,获取元素的线程会等待队列变为非空;
二:Java并发工具类:
包含CountDownLatch,CyclicBarrier,Semaphore;
(1)CountDownLatch:
允许一个线程或者多个线程等待其他线程完成操作;他主要是使用了线程的join();Thread.join()会一直去检测使用join的线程是否isAlive();如果isAlive(),就wait();
public static void main(String[] args) { Thread t1 = new Thread(new Runnable() { @Override public void run() { System.out.println("11111"); } }); t1.start(); try { System.out.println(t1.isAlive()); t1.join(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(" main is going"); }
(2)CyclicBarrier:可循环使用的屏障;
让一组线程到达一个屏障(也叫同步点)时被阻塞,知道最后一个线程到达屏障时,屏障才会开门,所有被拦截的线程才开始继续执行。
默认的构造方法:Cyclebarrier c = Cyclebarrier(int num);num表示拦截线程的数量,每个线程调用await()方法告诉CycleBarrier我已经到达了屏障,然后当前线程被阻塞。
public static void cycleBarrierTest() throws Exception { new Thread(new Runnable() { @Override public void run() { try { c.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println(11); } }).start(); c.await(); System.out.println(22); }
(3)Semaphore(信号量):
用来控制同时访问特定资源的线程数量,他通过协调各个线程,以保证合理的使用公共资源;比如数据库链接,30个线程,但是只有10个能同时进行;acquire获取进行许可证,release()释放;
public static void semaphoreTest(){ int thread_count = 30; ExecutorService pool = Executors.newFixedThreadPool(thread_count); Semaphore s = new Semaphore(10); for(int i =0;i<thread_count;i++){ pool.execute(new Runnable() { @Override public void run() { try { s.acquire(); System.out.println("save data"); s.release(); } catch (InterruptedException e) { e.printStackTrace(); } } }); } pool.shutdown(); }
相关文章推荐
- Java并发容器之阻塞队列简介
- 【死磕Java并发】-----J.U.C之阻塞队列:SynchronousQueue
- Java多线程/并发26、阻塞队列BlockingQueue
- Java并发编程 之 阻塞队列和CountDownLatch
- (java多线程与并发)java并发库中的阻塞队列--BlockingQueue
- Java并发编程:阻塞队列
- 【Java并发编程】并发新特性—阻塞队列和阻塞栈(含代码)
- java.util.concurrent系列之--并发队列ConcurrentLinkedQueue和阻塞队列LinkedBlockingQueue用法
- 【转载】Java并发编程12:阻塞队列
- java并发编程之阻塞队列
- Java并发框架——AQS阻塞队列管理(一)——自旋锁
- Java并发框架——AQS阻塞队列管理(二)——自旋锁优化
- [Java并发包学习九]Java中的阻塞队列
- java并发:阻塞队列
- java并发编程学习: 阻塞队列 使用 及 实现原理
- Java并发之阻塞队列
- 线程高级应用-心得7-java5线程并发库中阻塞队列Condition的应用及案例分析
- Java并发框架——AQS阻塞队列管理(一)——自旋锁
- Java多线程 阻塞队列和并发集合
- 转: 【Java并发编程】之二十一:并发新特性—阻塞队列和阻塞栈(含代码)