以固定速率安排 Callable

Question

我有一个任务想要以固定速率运行。但是我还需要每次执行后任务的结果。这是我尝试过的：

任务

class ScheduledWork implements Callable<String>
{
    public String call()
    {
        //do the task and return the result as a String
    }
}

否 我尝试使用 ScheduledExecutorService 来安排它。事实证明，您无法以固定速率安排 Callable，只有 Runnable 可以这样做。

请指教。

Answer 1

使用生产者/消费者模式：拥有可运行将其结果放在 BlockingQueue。有另一个线程 take( ) 从队列中。

Take 是一个阻塞调用（即仅当队列中有内容时才返回），因此您将在结果可用时立即获得结果。

您可以将其与 好莱坞模式 结合起来，为等待线程提供回调，以便您的代码被调用当有东西可用时。

Answer 2

除非您不关心 Callable 的返回值，否则您可以将其包装在 Runnable 中，并使用它传递给 ScheduledExecutorService 。

public static Runnable runnableOf(final Callable<?> callable)
{
    return new Runnable()
    {
        public void run()
        {
            try
            {
                callable.call();
            }
            catch (Exception e)
            {
            }
        }
    };
}

然后，当您想要提交到 ScheduledExecutroService 时，您可以传递您的 Callable：

ses.scheduleAtFixedRate(runnableOf(callabale), initialDelay, delay, unit);