java并发包中是否有任何执行器可以保证所有任务都按照提交的顺序完成？

Question

用于演示标题中的想法的代码示例：

executor.submit(runnable1);
executor.submit(runnable2);

我需要确保 runnable1 将在 runnable2 启动之前完成，并且我在执行程序文档中没有找到此类行为的任何证据。

关于我正在解决的问题： 我需要将大量日志写入文件。每个日志都需要大量的预计算（格式化和其他一些东西）。因此，我想将每个日志记录任务放入一种队列中，并在单独的线程中处理这些任务。当然，保持日志有序也很重要。

Answer 1

单线程执行器将按照提交的顺序执行所有任务。如果您希望同时执行任务，则只能使用具有多个线程的线程池。

将任务添加到队列本身的成本就很高。您可以使用这样的 Exchanger

http://vanillajava.blogspot.com/2011/09/exchange-and-gc-less-java.html?z#!/2011/09/exchange-and-gc-less-java。 html

这避免使用队列或创建对象。

另一种更快的替代方法是使用不需要后台线程的内存映射文件（实际上操作系统在后台工作），这又快得多。它支持亚微秒延迟和每秒数百万条消息。

https://github.com/peter-lawrey/Java-Chronicle

Answer 2

您可以创建一个像下面这样的简单包装器，以便所有 Runnables 都在同一线程中执行（即顺序执行），然后将该包装器提交给执行器。这并没有解决日志记录问题。

class MyRunnable implements Runnable {

    private List<Runnable> runnables = new ArrayList<>();

    public void add(Runnable r) {
        runnables.add(r);
    }
    @Override
    public void run() {
        for (Runnable r : runnables) {
            r.run();
        }
    }

}

//......
MyRunnable r = new MyRunnable();
r.add(runnable1);
r.add(runnable2);
executor.submit(r);    

Answer 3

想必您正在对日志文件进行一些后期分析？您是否考虑过不关心它们的编写顺序并稍后离线重新排序。您可以在提交时使用时间戳或 AtomicLong 分配唯一的 id？

代码草图（未经测试）如下所示：

import java.util.concurrent.atomic.AtomicLong;

class MyProcessor {

    public void work()
        for (Object data: allData) {
            executor.submit(new MySequencedRunnable(data);
        }
    }

}

class MySequencedRunnable implements Runnable {
    private static final AtomicLong LOG_SEQUENCE_ID = new AtomicLong(0);

    private final Object data;

    MySequencedRunnable(Object data) {
       this.data = data;

    }

    public void run() {
        LOGGER.log(LOG_SEQUENCE_ID.incrementAndGet(), data);
    }

}

另请考虑，如果您使用的是 log4j 之类的东西，请使用 NDC 或 MDC 协助重新订购。