Java 阻塞队列.Java并发工具类

原创
2017/08/03 00:21
阅读数 360

一:阻塞队列(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();
}
展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
在线直播报名
返回顶部
顶部