java线程并发semaphore类示例
package com.yao;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;/**
* Java 5.0里新加了4个协调线程间进程的同步装置,它们分别是:
* Semaphore, CountDownLatch, CyclicBarrier和Exchanger.
* 本例主要介绍Semaphore。
* Semaphore是用来管理一个资源池的工具,可以看成是个通行证,
* 线程要想从资源池拿到资源必须先拿到通行证,
* 如果线程暂时拿不到通行证,线程就会被阻断进入等待状态。
*/
public class MySemaphore extends Thread {private int i;
private Semaphore semaphore;
public MySemaphore(int i,Semaphore semaphore){
this.i = i;
this.semaphore = semaphore;
}
public void run(){
if(semaphore.availablePermits() > 0){
System.out.println(""+i+"有空位 : ");
}else{
System.out.println(""+i+"等待,没有空位 ");
}
try {
semaphore.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(""+i+"获得空位");
try {
Thread.sleep((int)Math.random()*10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(""+i+"使用完毕");
semaphore.release();
}
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(2);
ExecutorService service = Executors.newCachedThreadPool();
for(int i = 0 ;i<10 ; i++){
service.execute(new MySemaphore(i,semaphore));
}
service.shutdown();
semaphore.acquireUninterruptibly(2);
System.out.println("使用完毕,需要清扫了");
semaphore.release(2);
}}
您可能感兴趣的文章:
- Java并发系列之CountDownLatch源码分析
- Java并发系列之CyclicBarrier源码分析
- Java并发系列之ConcurrentHashMap源码分析
- Java并发系列之AbstractQueuedSynchronizer源码分析(共享模式)
- Java并发系列之AbstractQueuedSynchronizer源码分析(独占模式)
- Java并发系列之AbstractQueuedSynchronizer源码分析(概要分析)
- Java并发系列之ReentrantLock源码分析
- Java并发系列之AbstractQueuedSynchronizer源码分析(条件队列)
- Java并发系列之Semaphore源码分析
- Java并发系列之Semaphore源码分析
- java线程并发cyclicbarrier类使用示例
- Java并发编程示例(二):获取和设置线程信息
- java线程并发blockingqueue类使用示例
- Java并发编程示例(五):线程休眠与恢复
- Java并发编程示例(八):处理线程的非受检异常
- java线程并发blockingqueue类使用示例
- java并发和线程的几个示例类
- java线程入门示例
- Java并发库(一):传统线程技术回顾
- 【Java并发编程】之十二:线程间通信中notifyAll造成的早期通知问题(含代码)(r)
- 【Java多线程与并发库】20.java线程面试题3
- Java线程中对象及变量的并发访问
- Java高并发编程:线程锁技术
- Java线程:并发协作-生产者消费者模型
- java挑战高并发(7):java 线程中yield的用法
- 【Java并发编程】之二:线程中断(含代码)
- Java并发操作——基本的线程机制
- 张孝祥java.concurrent线程并发学习笔记 - concurrent简介
- Java并发——线程中断学习