首页 > 其他 > 详细

Semaphore并发包使用Demo

时间:2020-06-30 19:38:45      阅读:49      评论:0      收藏:0      [点我收藏+]

Semaphore常用方法说明

acquire()  
获取一个令牌在获取到令牌或者被其他线程调用中断之前线程一直处于阻塞状态?
acquire(int permits)  
获取一个令牌在获取到令牌或者被其他线程调用中断或超时之前线程一直处于阻塞状态acquireUninterruptibly() 
获取一个令牌在获取到令牌之前线程一直处于阻塞状态忽略中断)。
    
tryAcquire()
尝试获得令牌返回获取令牌成功或失败不阻塞线程?
tryAcquire(long timeout, TimeUnit unit)
尝试获得令牌在超时时间内循环尝试获取直到尝试获取成功或超时返回不阻塞线程?
release()
释放一个令牌唤醒一个获取令牌不成功的阻塞线程?
hasQueuedThreads()
等待队列里是否还存在等待线程?
getQueueLength()
获取等待队列里阻塞的线程数?
drainPermits()
清空令牌把可用令牌数置为0返回清空令牌的数量?
availablePermits()
返回可用的令牌数量

用semaphore 实现停车场提示牌功能。

 

每个停车场入口都有一个提示牌,上面显示着停车场的剩余车位还有多少,当剩余车位为0时,不允许车辆进入停车场,直到停车场里面有车离开停车场,这时提示牌上会显示新的剩余车位数。

 

业务场景 :

1、停车场容纳总停车量10。

2、当一辆车进入停车场后,显示牌的剩余车位数响应的减1.

3、每有一辆车驶出停车场后,显示牌的剩余车位数响应的加1。

4、停车场剩余车位不足时,车辆只能在外面等待。

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

/**
 * TestCar
 * 
 * @author Stephen
 * @time 2020-6-30 17:48:50
 */
public class TestCar {

	// 停车场同时容纳的车辆10
	private static Semaphore semaphore = new Semaphore(10);

	public static void main(String[] args) {

		// 模拟100辆车进入停车场
		for (int i = 0; i < 20; i++) {

			Thread thread = new Thread(new Runnable() {
				public void run() {
					try {
						System.out.println("==== " + Thread.currentThread().getName() + "来到停车场,停车位剩余:" + semaphore.availablePermits());
						if (semaphore.availablePermits() == 0) {
							System.out.println("车位不足,请耐心等待");
						}
						semaphore.acquire();// 获取令牌尝试进入停车场
						System.out.println(Thread.currentThread().getName() + "成功进入停车场");
						Thread.sleep(new Random().nextInt(10000));// 模拟车辆在停车场停留的时间
						System.out.println(Thread.currentThread().getName() + "驶出停车场");
						semaphore.release();// 释放令牌,腾出停车场车位
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}, (i + 1) + "号车");
			thread.start();
		}

	}
}

  

Semaphore并发包使用Demo

原文:https://www.cnblogs.com/dzcici/p/13215192.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!