吾爱破解 - 52pojie.cn

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 1034|回复: 4
收起左侧

[学习记录] java中Semaphore和Exchanger的实例代码和讲解

[复制链接]
黑白客 发表于 2022-11-21 10:57

Semaphore

解释

在java的阻塞方法中,有这样一个semaphore类,它可以允许指定的线程数同时运行,超过了指定数,则会阻塞等待获取的线程释放才会继续执行

实例代码

new semaphore(,)第一个参数permits是允许同时执行的数量,第二个参数是boolean类型,true为公平竞争,类似与公平锁。

演示代码

package ReentrantLock和LongAdder;

import javax.xml.crypto.Data;
import java.util.concurrent.Semaphore;

/**
 * @program: solution
 * @description: 演示Semaphore的使用方法 类似于信号灯
 * @author: Wang Hai Xin
 * @create: 2022-11-16 17:36
 **/
public class SemaphoreT {

    /*semaphore 类似于信号灯,创建的时候可以指定 permits(允许)的数量
    * 当超过这个数量之后,就会阻塞
    * */
    public static void main(String[] args) {
        Semaphore semaphore = new Semaphore(2);
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            new Thread(()->{
                try {
                    semaphore.acquire();
                    System.out.println("我是第:" + finalI+" time: "+ System.currentTimeMillis());
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }finally {
                    semaphore.release();
                }
            }).start();
        }
    }
}

运行结果如下,因为我们设置了semaphore的permits允许数量为2,所以可以看出两个两个时间相近 进入了方法

我是第:1 time: 1668591715626
我是第:0 time: 1668591715626
我是第:2 time: 1668591716639
我是第:3 time: 1668591716639
我是第:4 time: 1668591717646
我是第:5 time: 1668591717646
我是第:6 time: 1668591718647
我是第:7 time: 1668591718647
我是第:8 time: 1668591719658
我是第:9 time: 1668591719658

使用场景和作用

限流!!!

Exchanger线程之间交换数据

作用

用于线程之间交换数据,调用Exchanger方法之后,就会等待其它线程调用Exchanger方法来交换数据。等待这段时间是阻塞的。exchang()方法的参数就是要交换的数据,返回值就是交换回来的数据

实例代码

package ReentrantLock和LongAdder;

import java.util.concurrent.Exchanger;

/**
 * @program: solution
 * @description: 演示Exchanger实例代码,用于线程之间交换数据
 * @author: Wang Hai Xin
 * @create: 2022-11-16 17:53
 **/
public class ExchangerT {

    public static void main(String[] args) {
        Exchanger<Integer> exchanger = new Exchanger<>();

        /**/
        new Thread(() -> {
            int  i = 1;
            try {
                /*用来交换值,等待其它线程调用,如果没有其它线程调用,则会阻塞在这里*/
                i = exchanger.exchange(i);
                System.out.println("线程1的输出: "+ i);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }

        }).start();

        new Thread(() -> {
            int  i = 2;
            try {
                i = exchanger.exchange(i);
                System.out.println("线程2的输出: "+ i);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }

        }).start();

    }

}

运行结果

线程2的输出: 1
线程1的输出: 2

使用场景和作用

游戏里交换装备

免费评分

参与人数 3吾爱币 +3 热心值 +3 收起 理由
带俗 + 1 + 1 谢谢@Thanks!
唐小样儿 + 1 + 1 我很赞同!
lushihao + 1 + 1 欢迎分析讨论交流,吾爱破解论坛有你更精彩!

查看全部评分

发帖前要善用论坛搜索功能,那里可能会有你要找的答案或者已经有人发布过相同内容了,请勿重复发帖。

rashion 发表于 2022-11-21 11:04
感谢分享
lushihao 发表于 2022-11-21 11:52
带俗 发表于 2022-11-21 15:08
lizwan 发表于 2022-11-21 15:54
学习了,感谢分享
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

返回列表

RSS订阅|小黑屋|处罚记录|联系我们|吾爱破解 - LCG - LSG ( 京ICP备16042023号 | 京公网安备 11010502030087号 )

GMT+8, 2024-11-25 06:43

Powered by Discuz!

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表