java的Worker類如何用

本文小編為大家詳細(xì)介紹“java的Worker類如何用”，內(nèi)容詳細(xì)，步驟清晰，細(xì)節(jié)處理妥當(dāng)，希望這篇“java的Worker類如何用”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學(xué)習(xí)新知識(shí)吧。

說明

1、Worker是ThreadPoolexecutor的內(nèi)部類，主要用于維持線程執(zhí)行任務(wù)的中斷控制狀態(tài)。

2、在實(shí)現(xiàn)Runnable接口的同時(shí)繼承AQS，實(shí)現(xiàn)Runnable接口意味著Worker是線程。

實(shí)例

    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. */
       // 執(zhí)行任務(wù)的線程
        final Thread thread;
        /** Initial task to run.  Possibly null. */
       // 執(zhí)行的任務(wù)
        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) {
          // 新建線程的時(shí)候，設(shè)置state -1 是為了防止線程還未執(zhí)行時(shí)（線程只有在執(zhí)行的時(shí)候才會(huì)被中斷），就被     // 其它線程顯式調(diào)用shutdown方法中斷了，因?yàn)橹袛嗍且袛鄐tate大于等于0才會(huì)中斷
          setState(-1);
          this.firstTask = firstTask;
          // 新建了一個(gè)線程
          this.thread = getThreadFactory().newThread(this);
        }
 
        /** Delegates main run loop to outer runWorker  */
        public void run() {
            runWorker(this);
        }

讀到這里，這篇“java的Worker類如何用”文章已經(jīng)介紹完畢，想要掌握這篇文章的知識(shí)點(diǎn)還需要大家自己動(dòng)手實(shí)踐使用過才能領(lǐng)會(huì)，如果想了解更多相關(guān)內(nèi)容的文章，歡迎關(guān)注億速云行業(yè)資訊頻道。