newCachedThreadPool Metody

Başga bir tok bolsa – cached type. Bu toklar, ulanylyşy boýunça, fixed ýaly giňden ulanylýar.

Toklar cached edilýär, şonuň üçin ady şeýle. Ony işjeň (ulanylmaýan) saklaýar, belli bir wagta çenli, täze işleriň ýerine ýetirilmegi üçin bu toklar ulanylmaly. Şeýle toklar, ýerine ýetirmek üçin belli bir akyl ýetirilýän mukdarda ýeňil işler bar bolsa, iň gowusy ulanylýar.

"Akyl ýetirilýän mukdar" düşünmesi örän uzyn, emma belli bir mukdar işler üçin bu toklar ähli ýagdaýa laýyk däl. Mysal üçin, million iş yaratmak isleýän bolsak, olaryň hersi örän az wagt alýan bolsa hem, resurslary esassyz ulanyp, öndürijiligi peseldýäris. Şeýle hem, iş wagty öñünden çak edilmedik ýagdaýlarda, meselem, giriş-çykaryş işlerinde, bu tokdan gaça durmaly.

Python aşagyndaky gurşawda ThreadPoolExecutor konstruktory aşakdaky parametrler bilen çaýrylýar:

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, 
      new SynchronousQueue<Runnable>());
}

Konstruktor üçin parametrler hökmünde şu bahalar berilýär:

Başga parametro hökmünde biz öz ThreadFactory implementasiýamyzy berip bileris.

SynchronousQueue hakda gürleşeli

Synchronize geçiriliş ýatlaň örän sada, şol bir wagtyň özünde sezgileriňe garşy bolup biler (duýgy, aňdyrma, ýa-da duýgurlyk bilen baha berilende dogry däl ýaly görünýän): bir ýük diňe we diňe başga bir tok şol ýüküň kabul edýän wagty alýar. Başgaça aýtsak, sichronizirlenen nobatda dürli işler bolup bilmez, sebäbi täze iş kabul edilende, ýerine ýetiriji tok şol işi eýýäm alýar.

Täze iş nobata giren wagty, eger tokda boş ýer bolsa, tok şol işi alýar, eger ähli toklar meşgul bolsa — täze tok döredilýär.

Cached tok noýba toklar dolandyrylmagynda, esasanda ýagdaýa gönükdirilenligi bilen, giňden ulanylýar.

Sistem resurslaryny dolandyrmak üçin, cached toklar bir minutlap iş bolmadyk tokary ýykýarlar.

Gelin muňa tejribede barlap göreli, biz ulanyjynyň soragyna modelleşdirýän iş klassyny döredýäris:

public class Task implements Runnable {
   int taskNumber;

   public Task(int taskNumber) {
       this.taskNumber = taskNumber;
   }

   @Override
   public void run() {
       System.out.println("Ulanyjynyň soragy işledildi №" + taskNumber + " tokda " + Thread.currentThread().getName());
   }
}
    

main içinde biz newCachedThreadPool döredýäris, soň 3 işi ýerine ýetirmäge goşýarys. Şu ýerde hyzmatymyz ýagdaýyny görkezýäris (1).

Soň 30 sekuntda togtadýarys, soň başga bir işi ýerine ýetirmäge goýýarys we ýagdaýy görkezýäris (2).

Soňra esasy tokumyzy 70 sekunda togtadýarys, ýagdaýy görkezýäris (3) we täze 3 işi ýerine ýetirmäge goşýarys we ýagdaýy gaýtadan çap edýäris (4).

Ýagdaýlary çap etmezden öň, işi goşandan soň, häzirki netijäni görkezmek üçin sleep 1 sekunda goýarys.

ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 3; i++) {
            executorService.submit(new Task(i));
        }
 
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(1)
 
        TimeUnit.SECONDS.sleep(30);
 
        executorService.submit(new Task(3));
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(2)
 
        TimeUnit.SECONDS.sleep(70);
 
            System.out.println(executorService);	//(3)
 
        for (int i = 4; i < 7; i++) {
            executorService.submit(new Task(i));
        }
 
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(4)
        executorService.shutdown();

Şeýlelikde, ýerine ýetirişiň netijesi:

Her ädimde näme bolandygyny derňeýeli:

Şeýlelikde, biz başga ýönekeý tok dolandyryş hyzmatynyň iş prinsipi bilen tanyş bolduk.

Executors klasasynyň newCachedThreadPool metody, ýörite ThreadFactory obýekti geçýär.