百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分类 > 正文

Semaphore与Exchanger的区别(semaphore和signal)

ztj100 2025-07-02 00:18 3 浏览 0 评论

Semaphore 和 Exchanger 是 Java 并发编程中两个常用的同步工具类,它们都可以用于协调多个线程之间的执行顺序和状态,但它们的作用和使用方式有所不同:

Semaphore 类表示一个信号量,它可以用于限制同时访问某个共享资源的线程数量(即限制某段代码块的并发数)。Semaphore 初始化时需要指定一个许可数,每个线程执行前需要先获取一个许可,如果所有许可都被占用,则后续线程需要等待其他线程释放许可才能执行。Semaphore 可以用于控制并发线程的数量,或者限制某些操作的并发执行次数。

Exchanger 类表示一个交换器,它可以用于两个线程之间的数据交换。Exchanger 初始化时不需要指定任何参数,它提供了一个 exchange() 方法,当两个线程都调用了这个方法时,它们会交换数据并返回对方线程传递的数据。Exchanger 可以用于实现两个线程之间的数据交换,例如用于生产者-消费者模式中的数据传递。

因此,Semaphore 和 Exchanger 的主要区别在于:Semaphore 可以用于限制并发线程的数量或者限制某些操作的并发执行次数,而 Exchanger 只能用于两个线程之间的数据交换。此外,Semaphore 需要指定许可数,而 Exchanger 不需要。

// Semaphore 示例
import java.util.concurrent.Semaphore;

public class SemaphoreExample {

    public static void main(String[] args) throws InterruptedException {
      //如果 count=1,相当于变成了一个 synchronized 了(synchronized 和 ReentrantLock 都是一次只允许一个线程访问某个资源,
      //Semaphore(信号量)可以指定多个线程同时访问某个资源。)
        int count = 3;
        Semaphore semaphore = new Semaphore(count);
        
        for (int i = 0; i < count * 2; i++) {
            new Thread(() -> {
                try {
                    // 获取许可
                    semaphore.acquire();
                    // 模拟线程执行任务
                    System.out.println(Thread.currentThread().getName() + " 执行任务");
                    // 释放许可
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

// Exchanger 示例
import java.util.concurrent.Exchanger;

public class ExchangerExample {

    public static void main(String[] args) throws InterruptedException {
        Exchanger<String> exchanger = new Exchanger<>();
        
        new Thread(() -> {
            String data = "Hello";
            try {
                // 交换数据并返回对方线程传递的数据
                String result = exchanger.exchange(data);
                System.out.println(Thread.currentThread().getName() + " 收到数据:" + result);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        
        new Thread(() -> {
            String data = "World";
            try {
                // 交换数据并返回对方线程传递的数据
                String result = exchanger.exchange(data);
                System.out.println(Thread.currentThread().getName() + " 收到数据:" + result);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

以上代码示例中,Semaphore 用于限制并发线程的数量,Exchanger 用于两个线程之间的数据交换。

相关推荐

Docker安全开放远程访问连接权限(docker 远程授权访问)

1、Docker完全开放远程访问Docker服务完全开放对外访问权限操作如下:#开启端口命令(--permanent永久生效,没有此参数重启后失效)firewall-cmd--zone=pu...

SpringCloud系列——4OpenFeign简介及应用

学习目标什么是OpenFeign以及它的作用RPC到底怎么理解OpenFeign的应用第1章OpenFeign简介在前面的内容中,我们分析了基于RestTemplate实现http远程通信的方法。并...

Spring Boot集成qwen:0.5b实现对话功能

1.什么是qwen:0.5b?模型介绍:Qwen1.5是阿里云推出的一系列大型语言模型。Qwen是阿里云推出的一系列基于Transformer的大型语言模型,在大量数据(包括网页文本、书籍、代码等)...

JDK从8升级到21的问题集(jdk8升级到11)

一、背景与挑战1.升级动因oOracle长期支持策略o现代特性需求:协程、模式匹配、ZGC等o安全性与性能的需求oAI新技术引入的版本要求...

大白话详解Spring Cloud服务降级与熔断

1.Hystrix断路器概述1.1分布式系统面临的问题复杂分布式体系结构中的应用程序有数十个依赖关系,每个依赖关系在某些时候将不可避免地失败。这就造成有可能会发生...

面试突击43:lock、tryLock、lockInterruptibly有什么区别?

在Lock接口中,获取锁的方法有4个:lock()、tryLock()、tryLock(long,TimeUnit)、lockInterruptibly(),为什么需要这么多方法?这些方法都有...

了解网络编程 TCP/IP 协议与UDP 协议

因为iP地址比较难记忆,很多情况下可以使用域名代替iP地址。1.TCP/IP协议与UDP协议通过IP地址与端口号确定计算机在网络中的位置后,接下来考虑通讯的问题:因为不同计算机的软硬件平台...

Semaphore与Exchanger的区别(semaphore和signal)

Semaphore和Exchanger是Java并发编程中两个常用的同步工具类,它们都可以用于协调多个线程之间的执行顺序和状态,但它们的作用和使用方式有所不同:Semaphore类表示一个...

Java教程:什么是分布式任务调度?怎样实现任务调度?

通常任务调度的程序是集成在应用中的,比如:优惠卷服务中包括了定时发放优惠卷的的调度程序,结算服务中包括了定期生成报表的任务调度程序...

java多线程—Runnable、Thread、Callable区别

多线程编程优点:进程之间不能共享内存,但线程之间共享内存非常容易。系统创建线程所分配的资源相对创建进程而言,代价非常小。Java中实现多线程有3种方法:继承Thread类实现Runnable...

工厂模式详解(工厂模式是啥意思)

工厂模式详解简单工厂简单工厂模式(SimpleFactoryPattern)是指由一个工厂对象决定创建出哪一种产品类的实例。简单工厂适用于工厂类负责创建的对象较少的场景,且客户端只需要传入工厂类的...

我们程序员眼中的母亲节(你眼中的程序员是什么样子的?程序员的薪酬如何?)

导语:对于我们成人来说,尤其是漂泊在外的程序员,陪伴父母的时间太少了。每逢佳节倍思亲,我们流浪外在的游子应该深有感触。母亲,是世界上最伟大的人,她承载着对我们的爱,更是负担和压力。我们作为子女,只会嫌...

死锁的 4 种排查工具(死锁检测方法要解决两个问题)

死锁(DeadLock)指的是两个或两个以上的运算单元(进程、线程或协程),都在等待对方停止执行,以取得系统资源,但是没有一方提前退出,就称为死锁。死锁示例接下来,我们先来演示一下Java中最简...

1. 工厂模式详解(工厂模式示例)

我们的项目代码也是由简而繁一步一步迭代而来的,但对于调用者来说却是越来越简单化。简单工厂模式简单工厂模式(SimpleFactoryPattern)是指由一个工厂对象决定创建出哪一种产品类的实例。...

Jmeter(二十):jmeter对图片验证码的处理

jmeter对图片验证码的处理在web端的登录接口经常会有图片验证码的输入,而且每次登录时图片验证码都是随机的;当通过jmeter做接口登录的时候要对图片验证码进行识别出图片中的字段,然后再登录接口中...

取消回复欢迎 发表评论: