直接上代码
package org.jimmy.threadtest20181121;import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit;public class TestThread20181128 {public Semaphore semaphore = new Semaphore(2, true);public static void main(String[] args) {try {TestThread20181128 testThread20181128 = new TestThread20181128();LinkedBlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>();ThreadPoolExecutor201811281311 executor = new ThreadPoolExecutor201811281311(2, 10000, 3600, TimeUnit.SECONDS, workQueue);for(int i = 0 ; i < 10; i++) {String id = i + "";Thread thread = new Thread(testThread20181128.new LineUpThread(id));executor.submit(thread);}executor.shutdown();} catch(Exception e) {e.printStackTrace();}}class LineUpThread implements Runnable {private String id;public LineUpThread(String id) {this.id = id;}@Overridepublic void run() {try {if(semaphore.availablePermits() > 0){System.out.println("开始排队");}semaphore.acquire();System.out.println("轮到编号" + id + "的客户了,可以开始购票了!");System.out.println("编号" + id + "的客户已购票成功!");semaphore.release();} catch(Exception e) {e.printStackTrace();}}}}
运行结果:
