如何超时等待多个侦听器

Question

我有以下问题:

主线程运行我的应用程序的代码(每秒被调用几次)，并且在执行某个操作之前，它在某个时刻通知侦听器列表。然后，侦听器执行操作以从外部源收集数据，其中一些操作非常耗时。

现在，一方面，我想让每个监听器有机会在我继续运行主线程之前完成它的工作(因为在操作完成后数据可能会丢失或更改)，另一方面，我需要将整个通知收集过程限制为一定的超时，以保持合理的操作流。

无论如何，我希望任何没有时间完成工作的听众继续。

一些示例代码:

public class ExampleTimeoutNotifier {
    private static ArrayList<ExampleTimeoutNotifierListener> listeners;
    private static int timeOutInMillis;
    public static void main(String[] args) {
        timeOutInMillis = Integer.parseInt(args[0]);
        // ... the following code is being called repeatedly on the main thread:
            // How to limit the process timeout?
            for (ExampleTimeoutNotifierListener l : listeners) {
                l.collectBeforeAction();
            }
        // Do the action...
    }
    public interface ExampleTimeoutNotifierListener {
        public void collectBeforeAction();
    }
}

Answer 1

这是我正在使用的代码，它似乎工作得很好。我现在不会把它标记为我的选择，因为我不确定我这样做是正确的…

final long startTime = System.currentTimeMillis();
ArrayList<Thread> threads = new ArrayList<Thread>();
for (final ExampleTimeoutNotifierListener l : listeners) {
    Thread t = new Thread() {
        @Override
        public void run() {
            try {
                l.collectBeforeAction();
            } catch (Exception e) {}
        }
    };
    t.start();
    threads.add(t);
}
for (Thread t : threads) {
    try {
        long timeoutLeft = timeOutInMillis - (System.currentTimeMillis() - startTime);
        if (timeoutLeft < 1) break;
        t.join();
    } catch (InterruptedException e) {}
}