Java ExecutorService从Iterator读取任务

Question

我应该创建一个从迭代器中提取下一个任务的任务吗？或者有什么更好的方法来实现这一点？

Answer 1

一个快速的实验产生了这种效果。它当然应该展示一种方法。

我创建并运行一个ServiceFeeder，它通过execute方法向服务提供Runnables。

ExecutorService service = Executors.newFixedThreadPool(10);

class ServiceFeeder implements Runnable {
    final Iterator<Runnable> i;

    public ServiceFeeder(Iterator<Runnable> i) {
        this.i = i;
    }

    @Override
    public void run() {
        while (i.hasNext()) {
            service.execute(i.next());
        }
    }
}

public void test() throws Exception {
    System.out.println("Hello world!");
    // Demo Iterator<Runnable> - use yours.
    Iterator<Runnable> i = new Iterator<Runnable>() {
        volatile int n = 0;

        @Override
        public boolean hasNext() {
            return n < 100;
        }

        @Override
        public Runnable next() {
            return () -> System.out.println(n++);
        }
    };

    ServiceFeeder feeder = new ServiceFeeder(i);
    Thread feederThread = new Thread(feeder);
    feederThread.start();
    // Wait for the feeder to stop.
    feederThread.join();
    // Wait for the service to stop.
    service.shutdown();
}

这类工作，因为它打印的远远超过我的预期，但这不是一个问题，作为一个演示imho。