Учебники

Метод newFixedThreadPool

Июнь 3, 2019

Фиксированный пул потоков можно получить, вызвав статический метод newFixedThreadPool () класса Executors.

Синтаксис 

ExecutorService fixedPool = Executors.newFixedThreadPool(2);

где

  • Максимум 2 потока будут активны для обработки задач.

  • Если передано более двух потоков, они удерживаются в очереди, пока потоки не станут доступными.

  • Новый поток создается, чтобы занять его место, если поток завершается из-за сбоя во время выполнения, и завершение выполнения для исполнителя еще не вызвано.

  • Любой поток существует до тех пор, пока пул не будет закрыт.

Максимум 2 потока будут активны для обработки задач.

Если передано более двух потоков, они удерживаются в очереди, пока потоки не станут доступными.

Новый поток создается, чтобы занять его место, если поток завершается из-за сбоя во время выполнения, и завершение выполнения для исполнителя еще не вызвано.

Любой поток существует до тех пор, пока пул не будет закрыт.

пример

Следующая программа TestThread показывает использование метода newFixedThreadPool в среде, основанной на потоках.

Live Demo 

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestThread {
	
   public static void main(final String[] arguments) throws InterruptedException {
      ExecutorService executor = Executors.newFixedThreadPool(2);

      // Cast the object to its class type
      ThreadPoolExecutor pool = (ThreadPoolExecutor) executor;

      //Stats before tasks execution
      System.out.println("Largest executions: "
         + pool.getLargestPoolSize());
      System.out.println("Maximum allowed threads: "
         + pool.getMaximumPoolSize());
      System.out.println("Current threads in pool: "
         + pool.getPoolSize());
      System.out.println("Currently executing threads: "
         + pool.getActiveCount());
      System.out.println("Total number of threads(ever scheduled): "
         + pool.getTaskCount());

      executor.submit(new Task());
      executor.submit(new Task());

      //Stats after tasks execution
      System.out.println("Core threads: " + pool.getCorePoolSize());
      System.out.println("Largest executions: "
         + pool.getLargestPoolSize());
      System.out.println("Maximum allowed threads: "
         + pool.getMaximumPoolSize());
      System.out.println("Current threads in pool: "
         + pool.getPoolSize());
      System.out.println("Currently executing threads: "
         + pool.getActiveCount());
      System.out.println("Total number of threads(ever scheduled): "
         + pool.getTaskCount());

      executor.shutdown();
   }  

   static class Task implements Runnable {

      public void run() {
         
         try {
            Long duration = (long) (Math.random() * 5);
            System.out.println("Running Task! Thread Name: " +
               Thread.currentThread().getName());
               TimeUnit.SECONDS.sleep(duration);
            
            System.out.println("Task Completed! Thread Name: " +
               Thread.currentThread().getName());
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
   }
}

Это даст следующий результат.

416
Share: