zoukankan      html  css  js  c++  java
  • java中常用的并发工具类

    · 1. 等待多线程完成的CountDownLatch

    构造函数接收一个int类型的参数作为计数器,如果想等待N个点,就传入N。当调用CountDownLatch的countDown方法时,N就会减一,直至减为零。使用await方法等待,当N的值变为零,执行await的线程继续执行。

    public class CountDownTest {
    
        static CountDownLatch c = new CountDownLatch(2);
        static ExecutorService pool = Executors.newFixedThreadPool(2);
    
        public static void main(String agrs[]){
    
            pool.execute(new Runnable() {
                public void run() {
                    try {
                        TimeUnit.MILLISECONDS.sleep(3);
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                    System.out.println("This is A");
                    c.countDown();
                }
            });
    
    
            pool.execute(new Runnable() {
                public void run() {
                    try {
                        TimeUnit.MILLISECONDS.sleep(3);
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                    System.out.println("This is B");
                    c.countDown();
                }
            });
    
            try {
                c.await();
            }catch (InterruptedException e){
    
            }
            System.out.println("This is main");
        }
    }
    
    

    2. 同步屏障CyclicBarrier

    可循环使用的屏障。它要做的事情,让一组线程到达屏障时被阻塞,直到最后一个线程到达屏障时,屏障才会打开,所有被屏障拦截的线程才会继续运行。

    默认构造方法CyclicBarrier(int parties),其参数表示屏障拦截的线程数,每个线程调用await方法告诉CyclicBarrier已经到达屏障,然后当前线程阻塞。

    public class CylicBarrierTest {
    
        static CyclicBarrier c = new CyclicBarrier(2);
    
        static ExecutorService pool = Executors.newFixedThreadPool(2);
    
        public static void main(String args[]){
    
            pool.execute(new Runnable() {
                public void run() {
                    System.out.println("this is A");
                    try {
                        c.await();
                        System.out.println("this is Aa");
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                }
            });
    
            pool.execute(new Runnable() {
                public void run() {
                    System.out.println("this is B");
                    try {
                        c.await();
                        System.out.println("this is Bb");
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                }
            });
    
            pool.shutdown();
        }
    }
    
    

    3. CountDownLatch vs CyclicBarrier

    CountDownLatch的计数器只使用一次,而CyclicBarrier的计数器可以使用reset方法重置,重复使用

    4. 控制线程并发数的信号量 Semaphore

    控制有限哥线程使用资源。使用方法 Semaphore ss = new Semaphore(N), N表示最大的并发量,每个线程使用资源前调用ss.acquire()方法获取权限,使用完后调用ss.release()方法释放权限。

    5. 线程间的数据交换Exchanger

    它提供一个同步点,在这个同步点,两个线程可以交换彼此的数据。

    public class ExchangeTest {
    
        private static final Exchanger<String> exgr = new Exchanger<String>();
    
        private static ExecutorService pool = Executors.newFixedThreadPool(2);
    
        public static void main(String args[]){
    
    
            pool.execute(new Runnable() {
                public void run() {
                    String A = "银行流水A";
                    try {
                      A =   exgr.exchange(A);
                        System.out.println("A 当前的值:" + A);
                    }catch (InterruptedException e){
    
                    }
                }
            });
    
            pool.execute(new Runnable() {
                public void run() {
                    String B = "银行流水B";
                    try {
                        B = exgr.exchange(B);
                        System.out.println("B 当前的值:" + B);
                    }catch (InterruptedException e){
    
                    }
                }
            });
    
            pool.shutdown();
        }
    
    
  • 相关阅读:
    CMDB 理论
    分布式
    闲着无聊 一个python的,三级菜单。装逼版。
    献上一段,派遣网易云音乐,音频的代码。
    redis 安装
    selenium之 chromedriver与chrome版本映射表(更新至v2.46)
    简单的爬虫
    anaconda使用方法
    crm开发之用户重置密码
    模块和包,logging模块
  • 原文地址:https://www.cnblogs.com/graph/p/7086209.html
Copyright © 2011-2022 走看看