直接上代碼

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();}}}}

運行結果:

?

?

轉載于:https://www.cnblogs.com/JimmySeraph/p/10031776.html

總結

以上是生活随笔為你收集整理的java线程池,信号量使用demo的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。