Semaphore和Exchanger-阿里云开发者社区

Semaphore和Exchanger

2023-07-27 65

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Semaphore和Exchanger

公众号merlinsea

Semaphore

Semaphore信号量：用于约束在一个jvm中最多同时有多少个线程可以并发执行，即可以控制并发数量。
应用场景：主要用于单jvm中的接口限流。
关于信号量的核心操作：

在线程内代码执行前先尝试获取信号量
在线程内代码执行完毕或者出现异常的时候归还信号量。

public class SemaphoreDemo {
    public static void main(String[] args) {
        //一共有8个信号量
        Semaphore semaphore = new Semaphore(8);
        for (int i = 0; i < 10; i++) {
            new Thread(()->{
                try {
                    /**
                     * 获取一个信号量，只有获取到信号量到线程才可以向下执行
                     */
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "开始执行");
                    Thread.sleep(5000L);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    /**
                     * 归还信号量
                     */
                    semaphore.release();
                }
            }).start();
        }
    }
}

Exchanger

为单JVM实例的成对线程提供一个同步点，当两个线程都到达这个这个同步点上就可以交换数据，这两个线程通过执行exchange(msg)方法交换自己的数据，如果一个线程先执行exchange()方法，那么这个线程会在这个方法处一直等待到第二个线程执行到这个方法时就交换数据。
因此使用Exchanger的线程必须【成双】出现，否则会导致有一个线程阻塞在exchange方法。

public class ExchangerDemo {
    public static void main(String[] args) {
        Exchanger<String> stringExchanger = new Exchanger<>();
        new Thread(() -> {
            String str1 = "线程1的原始消息";
            System.out.println(Thread.currentThread().getName() + "初始值==========>" + str1);
            try {
                //线程1先执行，因此会在这个地方等待线程2
                String exchange = stringExchanger.exchange(str1);
                System.out.println(Thread.currentThread().getName() + "交換后的数据==========>" + exchange);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, "线程1").start();
        try {
            Thread.sleep(4000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        new Thread(() -> {
            String str2 = "线程2的原始消息";
            System.out.println(Thread.currentThread().getName() + "初始值==========>" + str2);
            try {
                //线程2执行到这里就会发生交换数据
                String exchange = stringExchanger.exchange(str2);
                System.out.println(Thread.currentThread().getName() + "交換后的数据==========>" + exchange);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, "线程2").start();
    }
}