Задача на собеседовании

[valyakol]

Пример задачи достаточно необычной, которую мне задали.

Comments

[lexicore]

Тоже сразу о Future подумал.

[magicprinc]

А вообще это мне одному кажется, что Future не хватает метода

void addListener(FutureListener listener); //можно вызывать много раз

public interface FutureListener extends EventListener {
void operationComplete(Future future) throws Exception;
}

чтобы:
Future f = ...
f.addListener(new FutureListener(){
public void operationComplete(Future future) throws Exception {
проверили успех, записали в БД/и тп и тд
}
});

Эдакий fire-and-forget

[sassa_nf]

http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/CompletionService.html

[magicprinc]

Это не совсем то, посмотрите там надо явно выбирать готовые futures.
А я говорю о том, чтобы получил Future и поручил ему самому в том потоке, где он "посчитается" доделать кой-какую работенку.

[sassa_nf]

в смысле?

schedule Future, который вызывает take(), блокируется до появления выполненного Future, и является Listener выполнения работы.

[alishka]

А как быть если на момент addListener() Future уже выполнилось? Придется городить либо нотификацию из отдельного трэда (но листнер должен быть уже готов принять нотификацию до завершения addListener()), либо забивать на нотификацию, но опять же клиенту городить собственную проверку не завершилось ли оно уже.
Если листнер, то надо запуск делать отдельной операцией, чего существующий API не предполагает.
ИМХО нужно более радикалиный редизайн экзекьютора делать для этого.

[magicprinc]

Случайно ответил в основной тред:
http://community.livejournal.com/ru_java/902522.html?thread=12052090#t12052090