直接上代码
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; } @Override public 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(); } } } }
运行结果: