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

[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]

зачот. с Future правильно и красиво.

а вот неправильно и некрасиво:

public Object invoke( final Object arg, long timeoutMs ) throws InterruptedException
{
final Object result[]=new Object[1];
synchronized( result )
{
Thread th = new Thread(){
public void run(){
result[0] = invoke( arg );
if ( result[ 0 ] == null ) result[0]=result;
synchronized( result )
{
result.notify();
}
}
};

th.start();
result.wait( timeoutMs );
th.interrupt();
// th.stop(); // if you know what you are doing
}

if ( result[ 0 ] == null ) throw new InterruptedException();
return result[ 0 ] == result ? null: result[ 0 ];
}

[jabberwack]

Я правильно понял, что требуется ограничить время выполнения метода? Т.е. если метод invoke(Object) выполняется дольше X милисекунд, то он должен просто прерываться?

Если нужно действительно это, то есть вот такая идея:

public void invoke(Object arg) throws MyException {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return in + " invoke";
}

public void timedInvoke(final Object arg, long millis) {

Thread thread = new Thread(
new Runnable() {
public void run() {
try {
invoke(obj);
} catch (MyException ex) {
ex.printStackTrace();
}
}
}
);
thread.start();

try {
thread.join(millis);
} catch (InterruptedException ignore) {}
if (thread.isAlive()) {
thread.interrupt();
}

}

[valyakol]

О, хороший пример. Этот ответ и ожидался, так как нужно было написать пример на бумаге.

[jabberwack]

А вот мне интересно - вариант с Future, если смотреть изнутри, то же самое делает? Или там какие-то инновационные технологии использованы?

[sassa_nf]

Future не может делать то же самое, поскольку Thread, который выполняет сам Callable может и не join до конца работы JVM. там скорее будет что-то типа wait(Object, long), но скорее всего с использованием java.util.concurrent

[magicprinc]

Здорово, вы помните про новые классы и их методы

[magicprinc]

Если
public Object invoke(Object in) throws MyException
объявлен в интерфейсе или его допускается модифицировать,
я бы проявил недюженное эстетство и предложил использовать

TimeLimiter.newProxy из библиотеки Guava от Google.

Против Гугла кто ж попробует возбухнуть ;-)