Доброго дня!
Есть класс, представляющий собой адрес (хост + порт), сообщение (msg) и результат доставки сообщения (done):
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
public class Message {
int id;
String host;
int port;
String msg;
boolean done;
// Геттеры и сеттеры
...
}
В процессе работы формируется список таких сообщений, который необходимо доставить по адресам:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
...
// Список сообщений для отправки
List<Message> messages = createMessageList();
int procNumber = Runtime.getRuntime().availableProcessors();
ExecutorService executor = Executors.newFixedThreadPool(procNumber);
CompletionService<Message> service = new ExecutorCompletionService<>(executor);
List<Future<Message>> futures = new ArrayList<>(messages.size());
for(int i = 0; i < messages.size(); i++) {
// Отправка; в классе MessageSender (implements Callable<Message>) открывается сокет, делается попытка отправки
// после чего устанавливается переменная done (успех/не успех)
futures.add(service.submit(new MessageSender(messages.get(i))));
}
// Размеры исходного списка (messages) и результирующего (futures) совпадают
LOG.info("{} : {}", messages.size(), futures.size());
// Теперь надо прочитать значение поля done - и тут облом
try {
for (int i = 0; i < futures.size(); i++) {
Future<Message> f = futures.get(i);
Message m = f.get();
LOG.info("{} : {}", i, f.getDone());
}
}
catch (InterruptedException ex) {}
catch (ExecutionException ex) {}
Все вроде ОК. Сообщения отправляются, результат выставляется (done = true/false), но распечатать я их не могу. Последний цикл проскакивает как будто печатать нечего, а на самом деле там может быть много элементов. Как сие победить? Спасибо
