import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; public class SemaphoreTest { //假若一个工厂有5台机器,但是有8个工人,一台机器同时只能被一个工人使用,只有使用完了, //其他工人才能继续使用。那么我们就可以通过Semaphore来实现 public static void main(String[] args) { ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(10); int num = 5 ; long start = System.currentTimeMillis(); Semaphore semaphore = new Semaphore(num); for (int i = 0; i < 8; i++) { newFixedThreadPool.submit(new SemaphoreRunnable(semaphore)); } long end = System.currentTimeMillis(); newFixedThreadPool.shutdown(); } public static class SemaphoreRunnable implements Runnable{ private Semaphore semaphore; public SemaphoreRunnable(Semaphore semaphore) { this.semaphore = semaphore; } @Override public void run() { try { long start = System.currentTimeMillis(); semaphore.acquire(); //Do some Thing Thread.sleep(1000); semaphore.release(); long end = System.currentTimeMillis(); System.out.println(System.currentTimeMillis() +"=========" + (end-start)/1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
捐助开发者
在兴趣的驱动下,写一个免费
的东西,有欣喜,也还有汗水,希望你喜欢我的作品,同时也能支持一下。 当然,有钱捧个钱场(支持支付宝和微信 以及扣扣群),没钱捧个人场,谢谢各位。
个人主页:http://knight-black-bob.iteye.com/
谢谢您的赞助,我会做的更好!
相关推荐
Semaphore 是一个强大的自动化部署工具,它使用 Ansible 来实现对多主机的配置管理。Ansible 是一个流行的 IT 自动化框架,它允许管理员通过编写 YAML 格式的 Playbook 来执行任务,如软件部署、配置管理和应用生命...
Semaphore是一款强大的持续集成/持续部署(CI/CD)工具,主要设计用于自动化软件构建、测试和部署流程。在这个"semaphore-develop.zip"压缩包中,包含的应该是Semaphore的开发源码,这对于理解其内部工作原理、自定义...
信号量(Semaphore)是操作系统中一种重要的同步机制,它用于管理多个线程对共享资源的访问,以防止并发执行时产生竞态条件。在多线程编程中,当多个线程试图同时访问一个有限的资源时,信号量可以帮助我们协调这些...
Swift中的`DispatchSemaphore`是GCD(Grand Central Dispatch)的一部分,它是Apple的多线程和并发解决方案。在iOS开发中,理解并熟练使用`DispatchSemaphore`对于优化代码性能和处理同步问题至关重要。本文将深入...
Semaphore(信号量)是一种经典的同步机制,它源自于荷兰计算机科学家Edsger W. Dijkstra提出的银行家算法。本示例中,我们将深入探讨如何使用Semaphore来控制多线程的循序执行。 Semaphore是一种计数信号量,它...
在 Ansible-semaphore.zip 文件中,包含的是 Semaphore 的源代码,特别是 "semaphore-master" 这个目录,这通常意味着它是项目的主分支或最新版本。 Semaphore 主要特点包括: 1. **Web GUI**:Semaphore 提供了一...
在C#编程中,Semaphore类是线程同步和并发控制的重要工具,主要用于限制对特定资源的并发访问。在这个实例中,我们关注的是如何利用Semaphore来管理多线程对多个端口的访问,确保不会出现冲突。Semaphore类可以看作...
标题提到的"pthread.h"、"sched.h"和"semaphore.h"是三个在多线程编程和进程调度中常用的头文件,特别是在Linux和类Unix系统中。然而,这里我们看到这些文件在Windows环境下使用Cygwin进行darknet编译时也有所需求。...
`mutex`(互斥锁)和`semaphore`(信号量)都是用于实现线程同步和互斥的工具,确保同一时间只有一个线程可以访问特定的共享资源。本文将深入探讨这两种机制及其在实际编程中的应用。 一、互斥锁(Mutex) 互斥锁是...
Semaphore是Windows操作系统中的一种同步机制,它用于控制多个进程对共享资源的访问。在这个"Semaphore进程间通讯测试源码"中,我们可以看到如何在MFC(Microsoft Foundation Classes)框架下利用Semaphore实现进程...
Linux 下多线程编程-Pthread 与 Semaphore 的使用 Linux 下的多线程编程是通过使用 POSIX 线程接口,称为 pthread 实现的。要编写 Linux 下的多线程程序,需要使用头文件 pthread.h,连接时需要使用库 libpthread.a...
### 利用Semaphore实现SHM进程通信:深入解析与实践 #### 进程通信概述 在多进程系统中,进程间通信(IPC)是确保不同进程之间能够共享数据和协调运行的关键技术。根据《利用semaphore实现shm进程通信》一文,主要...
Semaphore是Java并发编程中的一种重要工具,主要用于控制并发线程的访问权限,实现限流或资源的互斥访问。在高并发场景下,Semaphore能够有效地防止过多的线程同时访问共享资源,从而避免系统资源耗尽,提高系统性能...
Semaphore的使用及其方法的使用。
在ARM架构中,Semaphore的实现位于`arch/arm/kernel/semaphore.c`和`include/asm-arm/semaphore.h`文件中。 总的来说,Waitqueue、Event和Semaphore都是Linux内核提供的重要同步和互斥机制,它们在多线程环境下保证...
"hardware_semaphore2.zip"这个压缩包包含了一个硬件信号量的使用示例,对于初学者来说,理解这一概念是非常有益的。 硬件信号量是嵌入式系统中一种硬件支持的同步原语,与软件信号量相比,它的主要优势在于更高的...
在“基于SPOC的ucosii_Semaphore实验”中,我们将探讨如何利用SOPC(System on a Programmable Chip,可编程片上系统)技术和ucOS/II中的信号量机制来实现高效的资源管理。 SOPC技术是现代嵌入式系统设计的核心,它...
Semaphore T-BOX System OverviewPDF,Semaphore T-BOX System Overview
Semaphore是计数信号量。Semaphore管理一系列许可证。每个acquire方法阻塞,直到有一个许可证可以获得然后拿走一个许可证;每个release方法增加一个许可证,这可能会释放一个阻塞的acquire方法。然而,其实并没有...