您好,登錄后才能下訂單哦!
本文小編為大家詳細介紹“java的Worker類如何用”,內容詳細,步驟清晰,細節處理妥當,希望這篇“java的Worker類如何用”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來學習新知識吧。
說明
1、Worker是ThreadPoolexecutor的內部類,主要用于維持線程執行任務的中斷控制狀態。
2、在實現Runnable接口的同時繼承AQS,實現Runnable接口意味著Worker是線程。
實例
private final class Worker extends AbstractQueuedSynchronizer implements Runnable{ /** * This class will never be serialized, but we provide a * serialVersionUID to suppress a javac warning. */ private static final long serialVersionUID = 6138294804551838833L; /** Thread this worker is running in. Null if factory fails. */ // 執行任務的線程 final Thread thread; /** Initial task to run. Possibly null. */ // 執行的任務 Runnable firstTask; /** Per-thread task counter */ volatile long completedTasks; /** * Creates with given first task and thread from ThreadFactory. * @param firstTask the first task (null if none) */ Worker(Runnable firstTask) { // 新建線程的時候,設置state -1 是為了防止線程還未執行時(線程只有在執行的時候才會被中斷),就被 // 其它線程顯式調用shutdown方法中斷了,因為中斷是要判斷state大于等于0才會中斷 setState(-1); this.firstTask = firstTask; // 新建了一個線程 this.thread = getThreadFactory().newThread(this); } /** Delegates main run loop to outer runWorker */ public void run() { runWorker(this); }
讀到這里,這篇“java的Worker類如何用”文章已經介紹完畢,想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會,如果想了解更多相關內容的文章,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。