Понимание будущего/поточной обработки
Я пытаюсь использовать фьючерсы впервые. Это кажется умным, что можно отменить задание, но это не работает как ожидалось. В примере ниже, только отменяется первое задание. Остальные завершаются. Я неправильно понял использование фьючерсов?
public class ThreadExample
{
public static void main(String[] args) throws InterruptedException, ExecutionException
{
int processors = Runtime.getRuntime().availableProcessors();
System.out.println("Processors: " + processors);
ExecutorService es = Executors.newFixedThreadPool(processors);
int nowork = 10;
Future<Integer>[] workres = new Future[nowork];
for(int i = 0; i < nowork; i++)
{
workres[i] = es.submit(new SomeWork(i));
}
for(int i = 0; i < nowork; i++)
{
if(i % 2 == 0)
{
System.out.println("Cancel");
workres[i].cancel(true);
}
if(workres[i].isCancelled())
{
System.out.println(workres[i] + " is cancelled");
}
else
{
System.out.println(workres[i].get());
}
}
es.shutdown();
}
}
class SomeWork implements Callable<Integer>
{
private int v;
public SomeWork(int v)
{
this.v = v;
}
@Override
public Integer call() throws Exception
{
TimeUnit.SECONDS.sleep(5);
System.out.println(v + " done at " + (new Date()));
return v;
}
}
Вывод:
Processors: 4
Cancel
java.util.concurrent.FutureTask@10d448 is cancelled
4 done at Wed May 12 17:47:05 CEST 2010
2 done at Wed May 12 17:47:05 CEST 2010
1 done at Wed May 12 17:47:05 CEST 2010
3 done at Wed May 12 17:47:05 CEST 2010
1
Cancel
2
3
Cancel
4
5 done at Wed May 12 17:47:10 CEST 2010
7 done at Wed May 12 17:47:10 CEST 2010
8 done at Wed May 12 17:47:10 CEST 2010
6 done at Wed May 12 17:47:10 CEST 2010
5
Cancel
6
7
Cancel
8
9 done at Wed May 12 17:47:15 CEST 2010
9
2 ответа
Проблема в том, что ваш цикл отмены перекрывается с вашим циклом get () , который блокируется. Я думаю, вы хотите иметь 2 петли, не так ли? Один цикл, который отменяет задания с четными номерами, а затем второй цикл, который проверяет, какие из них отменены, а какие нет, и затем get () соответственно.
Так, как это написано прямо сейчас, еще до того, как цикл смог отменить workres [2] , он проверил и запросил get () у workres [ 1] .
Думаю, вам нужно 3 фазы:
1. The `submit()` loop
2. The selective `cancel()` loop
3. The selective `get()` loop (which blocks)
Future # cancel () не завершает / не прерывает уже выполняющиеся задания. Это отменит только еще не запущенные задания.
Обновление : полигенные смазочные материалы устраняют основную причину (+1): вот улучшенный код:
int processors = Runtime.getRuntime().availableProcessors();
System.out.println("Processors: " + processors);
ExecutorService es = Executors.newFixedThreadPool(processors);
int nowork = 10;
Future<Integer>[] workers = new Future[nowork];
for (int i = 0; i < nowork; i++) {
final int ii = i;
workers[i] = es.submit(new Callable<Integer>() {
public Integer call() throws Exception {
return ii;
}
});
}
for (int i = 0; i < nowork; i++) {
if (i % 2 == 0) {
System.out.println("Cancel worker " + i);
workers[i].cancel(true);
}
}
for (int i = 0; i < nowork; i++) {
if (workers[i].isCancelled()) {
System.out.println("Worker " + i + " is cancelled");
} else {
System.out.println("Worker " + i + " returned: " + workers[i].get());
}
}
es.shutdown();
Результат:
Processors: 2 Cancel worker 0 Cancel worker 2 Cancel worker 4 Cancel worker 6 Cancel worker 8 Worker 0 is cancelled Worker 1 returned: 1 Worker 2 is cancelled Worker 3 returned: 3 Worker 4 is cancelled Worker 5 returned: 5 Worker 6 is cancelled Worker 7 returned: 7 Worker 8 is cancelled Worker 9 returned: 9
(обратите внимание, что это рабочих , а не рабочих. ).