Учебники

Параллелизм Java — Фьючерсы и Callables

Июнь 3, 2019

Объект java.util.concurrent.Callable может возвращать вычисленный результат, выполненный потоком, в отличие от запускаемого интерфейса, который может только запустить поток. Объект Callable возвращает объект Future, который предоставляет методы для отслеживания хода выполнения задачи потоком. Будущий объект может быть использован для проверки состояния вызываемого объекта и последующего извлечения результата из вызываемого объекта после завершения потока. Это также обеспечивает функциональность тайм-аута.

Синтаксис 

//submit the callable using ThreadExecutor
//and get the result as a Future object
Future<Long> result10 = executor.submit(new FactorialService(10));
 
//get the result using get method of the Future object
//get method waits till the thread execution and then return the result of the execution.
Long factorial10 = result10.get();

пример

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

Live Demo 

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException,
      ExecutionException {

      ExecutorService executor = Executors.newSingleThreadExecutor();

      System.out.println("Factorial Service called for 10!");
      Future<Long> result10 = executor.submit(new FactorialService(10));

      System.out.println("Factorial Service called for 20!");
      Future<Long> result20 = executor.submit(new FactorialService(20));

      Long factorial10 = result10.get();
      System.out.println("10! = " + factorial10);

      Long factorial20 = result20.get();
      System.out.println("20! = " + factorial20);

      executor.shutdown();
   }  

   static class FactorialService implements Callable<Long> {
      private int number;

      public FactorialService(int number) {
         this.number = number;
      }

      @Override
      public Long call() throws Exception {
         return factorial();
      }

      private Long factorial() throws InterruptedException {
         long result = 1; 
         
         while (number != 0) { 
            result = number * result; 
            number--; 
            Thread.sleep(100); 
         }
         return result;	
      }
   }
}

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

50
Share: