`
wubo.wb
  • 浏览: 28653 次
  • 来自: 成都
文章分类
社区版块
存档分类
最新评论

Semaphore

阅读更多
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class Phonebooth {
	public static final int N = 5;

	public static void main(String[] args) {
		Semaphore semaphore = new Semaphore(N);
		ExecutorService service = Executors.newCachedThreadPool();
		for (int i = 0; i < 2 * N; i++) {
			service.execute(new Person(semaphore));
		}
		service.shutdown();
	}
}


import java.util.Random;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class Person implements Runnable {
	private Semaphore semaphore;

	public Person(Semaphore semaphore) {
		this.semaphore = semaphore;
	}

	public void run() {
		String name = Thread.currentThread().getName();
		try {
			System.out.println(name + " 等待进入电话亭...");
			semaphore.acquire();
			System.out.println(name + " 进入电话亭通话中...");
			TimeUnit.SECONDS.sleep(new Random().nextInt(10));
			System.out.println(name + " 出电话亭...");
			semaphore.release();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

Console
pool-1-thread-1 等待进入电话亭...
pool-1-thread-1 进入电话亭通话中...
pool-1-thread-3 等待进入电话亭...
pool-1-thread-3 进入电话亭通话中...
pool-1-thread-3 出电话亭...
pool-1-thread-5 等待进入电话亭...
pool-1-thread-2 等待进入电话亭...
pool-1-thread-2 进入电话亭通话中...
pool-1-thread-5 进入电话亭通话中...
pool-1-thread-4 等待进入电话亭...
pool-1-thread-4 进入电话亭通话中...
pool-1-thread-5 出电话亭...
pool-1-thread-6 等待进入电话亭...
pool-1-thread-6 进入电话亭通话中...
pool-1-thread-8 等待进入电话亭...
pool-1-thread-8 进入电话亭通话中...
pool-1-thread-10 等待进入电话亭...
pool-1-thread-7 等待进入电话亭...
pool-1-thread-9 等待进入电话亭...
pool-1-thread-1 出电话亭...
pool-1-thread-10 进入电话亭通话中...
pool-1-thread-2 出电话亭...
pool-1-thread-7 进入电话亭通话中...
pool-1-thread-6 出电话亭...
pool-1-thread-9 进入电话亭通话中...
pool-1-thread-7 出电话亭...
pool-1-thread-4 出电话亭...
pool-1-thread-10 出电话亭...
pool-1-thread-9 出电话亭...
pool-1-thread-8 出电话亭...
分享到:
评论

相关推荐

    semaphore完整搭建ansible部署方案

    Semaphore 是一个强大的自动化部署工具,它使用 Ansible 来实现对多主机的配置管理。Ansible 是一个流行的 IT 自动化框架,它允许管理员通过编写 YAML 格式的 Playbook 来执行任务,如软件部署、配置管理和应用生命...

    semaphore-develop.zip

    Semaphore是一款强大的持续集成/持续部署(CI/CD)工具,主要设计用于自动化软件构建、测试和部署流程。在这个"semaphore-develop.zip"压缩包中,包含的应该是Semaphore的开发源码,这对于理解其内部工作原理、自定义...

    使用信号量(Semaphore)实现线程的同步

    信号量(Semaphore)是操作系统中一种重要的同步机制,它用于管理多个线程对共享资源的访问,以防止并发执行时产生竞态条件。在多线程编程中,当多个线程试图同时访问一个有限的资源时,信号量可以帮助我们协调这些...

    Swift-dispatch-semaphore

    Swift中的`DispatchSemaphore`是GCD(Grand Central Dispatch)的一部分,它是Apple的多线程和并发解决方案。在iOS开发中,理解并熟练使用`DispatchSemaphore`对于优化代码性能和处理同步问题至关重要。本文将深入...

    semaphore控制多线程循序执行

    Semaphore(信号量)是一种经典的同步机制,它源自于荷兰计算机科学家Edsger W. Dijkstra提出的银行家算法。本示例中,我们将深入探讨如何使用Semaphore来控制多线程的循序执行。 Semaphore是一种计数信号量,它...

    C#语言Semaphore类用法实例(多线程多端口使用端口控制)

    在C#编程中,Semaphore类是线程同步和并发控制的重要工具,主要用于限制对特定资源的并发访问。在这个实例中,我们关注的是如何利用Semaphore来管理多线程对多个端口的访问,确保不会出现冲突。Semaphore类可以看作...

    pthread.h sched.h semaphore.h 三个头文件

    标题提到的"pthread.h"、"sched.h"和"semaphore.h"是三个在多线程编程和进程调度中常用的头文件,特别是在Linux和类Unix系统中。然而,这里我们看到这些文件在Windows环境下使用Cygwin进行darknet编译时也有所需求。...

    mutex和semaphore互斥程序实例

    `mutex`(互斥锁)和`semaphore`(信号量)都是用于实现线程同步和互斥的工具,确保同一时间只有一个线程可以访问特定的共享资源。本文将深入探讨这两种机制及其在实际编程中的应用。 一、互斥锁(Mutex) 互斥锁是...

    Semaphore进程间通讯测试源码

    Semaphore是Windows操作系统中的一种同步机制,它用于控制多个进程对共享资源的访问。在这个"Semaphore进程间通讯测试源码"中,我们可以看到如何在MFC(Microsoft Foundation Classes)框架下利用Semaphore实现进程...

    Linux下多线程编程-Pthread与Semaphore的使用.doc

    Linux 下多线程编程-Pthread 与 Semaphore 的使用 Linux 下的多线程编程是通过使用 POSIX 线程接口,称为 pthread 实现的。要编写 Linux 下的多线程程序,需要使用头文件 pthread.h,连接时需要使用库 libpthread.a...

    Ansible-semaphore.zip

    在 Ansible-semaphore.zip 文件中,包含的是 Semaphore 的源代码,特别是 "semaphore-master" 这个目录,这通常意味着它是项目的主分支或最新版本。 Semaphore 主要特点包括: 1. **Web GUI**:Semaphore 提供了一...

    利用semaphore实现shm进程通信

    ### 利用Semaphore实现SHM进程通信:深入解析与实践 #### 进程通信概述 在多进程系统中,进程间通信(IPC)是确保不同进程之间能够共享数据和协调运行的关键技术。根据《利用semaphore实现shm进程通信》一文,主要...

    Semaphore 源码解析

    Semaphore是Java并发编程中的一种重要工具,主要用于控制并发线程的访问权限,实现限流或资源的互斥访问。在高并发场景下,Semaphore能够有效地防止过多的线程同时访问共享资源,从而避免系统资源耗尽,提高系统性能...

    Semaphore的使用及其方法的使用

    Semaphore的使用及其方法的使用。

    Waitqueue、Event及Semaphore的实现机制分析

    在ARM架构中,Semaphore的实现位于`arch/arm/kernel/semaphore.c`和`include/asm-arm/semaphore.h`文件中。 总的来说,Waitqueue、Event和Semaphore都是Linux内核提供的重要同步和互斥机制,它们在多线程环境下保证...

    hardware_semaphore2.zip

    "hardware_semaphore2.zip"这个压缩包包含了一个硬件信号量的使用示例,对于初学者来说,理解这一概念是非常有益的。 硬件信号量是嵌入式系统中一种硬件支持的同步原语,与软件信号量相比,它的主要优势在于更高的...

    Semaphore_TBOX_产品-软件及系统功能

    根据提供的信息,我们可以深入探讨Semaphore_TBOX产品的软件及系统功能,特别是TBoxRTU的相关细节。这是一款专门针对工业自动化领域的远程终端单元(RTU),它不仅具备强大的数据采集能力,还集成了先进的软件工具,使...

    基于SPOC的ucosii_Semaphore实验

    在“基于SPOC的ucosii_Semaphore实验”中,我们将探讨如何利用SOPC(System on a Programmable Chip,可编程片上系统)技术和ucOS/II中的信号量机制来实现高效的资源管理。 SOPC技术是现代嵌入式系统设计的核心,它...

    Semaphore T-BOX System Overview.PDF

    Semaphore T-BOX System OverviewPDF,Semaphore T-BOX System Overview

Global site tag (gtag.js) - Google Analytics