事件驱动的未来<V> - 线程池

Question

我们使用callable<V>和Future<V>从线程池中接收终止线程的结果。我们应该调用get()来接收返回的结果。我的问题是:它不是事件驱动的。是否有任何框架来获得像SIGCHLD这样的结果在C中的子进程?我想要这样的东西:(线程池将在池中的每个线程完成任务时调用此函数)

public void fetchResult(Thread t, Runnable r, Future<Integer> result) {
    Integer x = result.get();
    /* handle x */
    /* also we have Thread and Runnable object that has terminated */
}

Answer 1

您可能想要检查ThreadPoolExecutor.afterExecute()方法。它在每个任务完成后被调用。你可以创建一个ThreadPoolExecutor的自定义子类，它具有你想要的基于事件的回调行为。

Answer 2

您可以轻松地创建一个事件驱动的模板。下面的伪代码说明了一种方法。

abstract class EventTemplate<T> implements Runnable {
    private BlockingQueue<T> queue; 
    public void submit(Callable<T> callable) {
        queue.add(callable);
    }
    public abstract void handleEvent(T t);
    public void run() {
        for(;;) handleEvent(queue.take());
    }
    public void start() {
         new Thread(this).start();
    }
}

类可以扩展模板

class FooEventHandler extends EventTemplate<Foo> {
    public void handleEvent(Foo foo) {
        // do something 
    }
}

可以实例化

new FooEventHandler().start();