1.信号量:java.util.concurrent的一个工具类,可以设置参数,控制同时访问的个数;主要有方法acquire(),release()获取和释放令牌;可以用于限流操作。
2、停车场demo
package com.ydlclass.collection;
import com.ydlclass.lock.ThreadUtil;
import java.util.Random;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class SemaphoreTest {
public static void main(String[] args) {
final Semaphore semaphore = new Semaphore(5);//定义信号量为5
ExecutorService executorService = Executors.newCachedThreadPool();//可缓存的线程池,不限制线程的个数
for (int i = 0; i < 100; i++) {
Runnable task = () -> {
try {
semaphore.acquire();//首先让线程拿到令牌
System.out.println("开进一辆车");
Thread.sleep(new Random().nextInt(15));//假设每辆车随机在停车场停留了一段时间
System.out.println("开出一辆车");
semaphore.release();
} catch (InterruptedException e){
e.printStackTrace();
}
};
executorService.execute(task);//执行线程池中task
}
executorService.shutdown();//关闭线程池
}
}