Пример программы на Java FutureTask

Когда-то я написал сообщение о интерфейсах Java Callable Future, которые мы можем использовать для получения преимуществ параллельной обработки потоков, а также они способны возвращать значение вызывающей программе. FutureTask является основной конкретной реализацией интерфейса Future и обеспечивает асинхронную обработку. Он содержит методы для запуска и отмены задачи, а также методы, которые могут возвращать состояние FutureTask, такие как завершена она или отменена. Нам нужен объект callable для создания будущей задачи, а затем мы можем использовать Java Thread Pool Executor для их асинхронной обработки. Давайте посмотрим на пример FutureTask с простой программой. Поскольку FutureTask требует объект callable, мы создадим простую реализацию Callable.

package com.journaldev.threads;

import java.util.concurrent.Callable;

public class MyCallable implements Callable {

	private long waitTime;
	
	public MyCallable(int timeInMillis){
		this.waitTime=timeInMillis;
	}
	@Override
	public String call() throws Exception {
		Thread.sleep(waitTime);
        //вернуть имя потока, выполняющего эту вызываемую задачу
        return Thread.currentThread().getName();
	}

}

Вот пример метода FutureTask, и здесь показаны общеиспользуемые методы FutureTask.

package com.journaldev.threads;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class FutureTaskExample {

	public static void main(String[] args) {
		MyCallable callable1 = new MyCallable(1000);
		MyCallable callable2 = new MyCallable(2000);

		FutureTask futureTask1 = new FutureTask(callable1);
		FutureTask futureTask2 = new FutureTask(callable2);

		ExecutorService executor = Executors.newFixedThreadPool(2);
		executor.execute(futureTask1);
		executor.execute(futureTask2);
		
		while (true) {
			try {
				if(futureTask1.isDone() && futureTask2.isDone()){
					System.out.println("Done");
					//выключить службу исполнителя
					executor.shutdown();
					return;
				}
				
				if(!futureTask1.isDone()){
				//ждать вечно, пока будущая задача не завершится
				System.out.println("FutureTask1 output="+futureTask1.get());
				}
				
				System.out.println("Waiting for FutureTask2 to complete");
				String s = futureTask2.get(200L, TimeUnit.MILLISECONDS);
				if(s !=null){
					System.out.println("FutureTask2 output="+s);
				}
			} catch (InterruptedException | ExecutionException e) {
				e.printStackTrace();
			}catch(TimeoutException e){
				//ничего не делать
			}
		}
		
	}

}

Когда мы запускаем вышеуказанную программу, вы заметите, что в течение некоторого времени она ничего не выводит, потому что метод get() класса FutureTask ожидает завершения задачи, а затем возвращает объект вывода. Также есть перегруженный метод, который позволяет ждать только указанное количество времени, и мы используем его для futureTask2. Также обратите внимание на использование метода isDone() для обеспечения завершения программы после выполнения всех задач. Вывод вышеуказанной программы будет:

FutureTask1 output=pool-1-thread-1
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
FutureTask2 output=pool-1-thread-2
Done

По сути, нет никакой выгоды от использования FutureTask, но он пригоден, когда мы хотим переопределить некоторые методы интерфейса Future и не хотим реализовывать каждый метод интерфейса Future.