事件驱动的未来- 线程池

Question

我们使用 callable 和 Future 从线程池接收终止线程的结果。我们应该调用get()来接收返回的结果。我的问题是：它不是事件驱动的。是否有任何框架可以为 C 中的子进程获取类似 SIGCHLD 的结果？ 我想要这样的东西：（当池中的每个线程完成工作时，线程池将调用这个函数）

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();