正确的方法使多个线程执行单个任务

Question

我正在尝试在一个间隔上执行单个函数foo，并且每个间隔多次。

我目前正在这样做的方式是通过创建使用指定的任何内容的newscheduledthreadpool创建服务（在此示例中说5）。因此，预定的线程池将用5个池实例化。

这是正确的方法吗？

当前，每个间隔都执行5次功能（在功能中放置一个打印语句，并看到每个间隔打印5次），但想检查这是否是此用例的正确方法。

    service = Executors.newScheduledThreadPool(threadPoolSize, runnable -> {
        Thread t = new Thread(runnable, "Test");
        t.setDaemon(true);
        return t;
    });

     this.start();
    }

    void start() {
        long initialDelay = frequencySecs + ThreadLocalRandom.current().nextInt(frequencySecs);
        for (int i = 0; i < threadPoolSize; i++) {
            service.scheduleAtFixedRate(this::foo, initialDelay, frequencySecs, MILLISECONDS);
        }
    }

Answer 1

我不知道您的函数的上下文和目的是因为您没有足够提及，具体取决于上下文，您可能会在并行的多个线程（如同步问题）中遇到一些问题。但是，如果您的上下文不需要同步，则可以使用执行相同函数的多个线程。

如果您不需要真正的并行化，则此实现将要简单得多：

private int scheduleCount = 0; // Global to the class

//...

private void foo(int executionCount) {
    System.out.println(String.format("Schedule times %d, execution times %d", scheduleCount, i));
}

//...

Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(()-> {
    scheduleCount++;
    for(int i = 1; i <= 5; i++) {
        foo(i);
    }
}, 300, 300, TimeUnit.MILLISECONDS);

这是输出日志：

I/System.out: Schedule times 1, execution times 1
I/System.out: Schedule times 1, execution times 2
I/System.out: Schedule times 1, execution times 3
I/System.out: Schedule times 1, execution times 4
I/System.out: Schedule times 1, execution times 5
I/System.out: Schedule times 2, execution times 1
I/System.out: Schedule times 2, execution times 2
I/System.out: Schedule times 2, execution times 3
I/System.out: Schedule times 2, execution times 4
I/System.out: Schedule times 2, execution times 5
I/System.out: Schedule times 3, execution times 1
I/System.out: Schedule times 3, execution times 2
I/System.out: Schedule times 3, execution times 3
I/System.out: Schedule times 3, execution times 4
I/System.out: Schedule times 3, execution times 5
I/System.out: Schedule times 4, execution times 1
I/System.out: Schedule times 4, execution times 2
I/System.out: Schedule times 4, execution times 3
I/System.out: Schedule times 4, execution times 4
I/System.out: Schedule times 4, execution times 5

请注意，您可能需要一个句柄来安排的executor服务，以便在不需要的情况下可以将其关闭。