Автор оригинала: Pankaj Kumar.
Некоторое время назад я написал сообщение о будущих вызываемых интерфейсах Java, которые мы можем использовать для получения преимуществ параллельной обработки потоков, а также для того, чтобы они могли возвращать значение вызывающей программе.
FutureTask является базовой конкретной реализацией будущего интерфейса и обеспечивает асинхронную обработку. Он содержит методы для запуска и отмены задачи, а также методы, которые могут возвращать состояние будущей задачи независимо от того, завершена она или отменена. Нам нужен вызываемый объект для создания будущей задачи, а затем мы можем использовать исполнителя пула потоков Java для асинхронной обработки этих задач.
Давайте рассмотрим пример FutureTask с простой программой.
Поскольку FutureTask требует вызываемого объекта, мы создадим простую вызываемую реализацию.
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 the thread name executing this callable task 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); FutureTaskfutureTask1 = 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"); //shut down executor service executor.shutdown(); return; } if(!futureTask1.isDone()){ //wait indefinitely for future task to complete 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){ //do nothing } } } }
Когда мы запустим вышеуказанную программу, вы заметите, что она некоторое время ничего не печатает, потому что get()
метод FutureTask ожидает завершения задачи, а затем возвращает выходной объект. Существует также перегруженный метод, позволяющий ждать только указанное время, и мы используем его для будущей задачи 2. Также обратите внимание на использование метода 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, но это удобно, когда мы хотим переопределить некоторые методы будущего интерфейса и не хотим реализовывать каждый метод будущего интерфейса.