У меня СТРАННАЯ проблема с Future.get() в Java. Он всегда возвращается с InterruptedException, однако странно то, что причина Exception равна null, поэтому я не могу сказать, кто меня прервал.
Ситуация становится еще хуже, потому что я проверяю перед вызовом get(), а работа, которую должен выполнить Future, уже выполнена.
Вот код, отвечающий за вывод ниже. f — это Future, а вызываемый объект возвращает HashMap, где Agent не имеет значения. Извините, если слишком много строк для печати, я просто пытаюсь дать как можно больше информации. Метод вызова из callable на данный момент представляет собой простой System.out.println("Hola soy agente")
, который, как вы увидите, выводится на печать, а это означает, что вызываемый объект также не вызывал исключения.
Вот код:
try
{
System.out.println(f.isDone()); //true
System.out.println(f.isCancelled()); //false
System.out.println(f.toString()); //FutureTask
newModdedAgents.putAll(f.get());
}catch(InterruptedException e)
{
System.out.println(f.isDone()); //true
System.out.println(f.isCancelled()); //false
System.err.println(e); //It is an interruptedException
System.err.println(e.getCause()); //???? null?
e.printStackTrace();
}
И вывод
Hola soy agente
true
false
java.util.concurrent.FutureTask@1c4c94e5
true
false
java.lang.InterruptedException
null
java.lang.InterruptedException
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1302)
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:248)
at java.util.concurrent.FutureTask.get(FutureTask.java:111)
at com.pf.simulator.Simulation.simulateStep(Simulation.java:217)
at com.pf.gui.ButtonPanel.doWork(ButtonPanel.java:141)
at com.pf.gui.ButtonPanel$1$1.construct(ButtonPanel.java:198)
at com.pf.gui.SwingWorker$2.run(SwingWorker.java:117)
at java.lang.Thread.run(Thread.java:636)
Если вы хотите увидеть, где я помещаю вызываемый объект в пул потоков... тогда это будет код для него
for(Callable<HashMap<Integer, Agent>> c : agentCallables)
{
Future<HashMap<Integer,Agent>> future = pool.submit(c);
agentFutureSet.add(future);
}
и после этого я перебираю этот набор с помощью
for(Future<HashMap<Integer, Agent>> f : agentFutureSet)
try
{
//Here goes the code at the beginning