OmnithreadLibrary 是否支持“工作窃取”？

Question

工作窃取例如在 Java 平台上的 Fork / Join 框架中可用。 （参见How is the fork/join framework better than a thread pool?）- OmniThreadLibrary 是否可以实现类似的功能？

---

工作窃取：无事可做的工作线程可以窃取其他人的任务 仍然很忙的线程。

Answer 1

我不知道我是否会将这种技术称为“工作窃取”，但确实 OmniThreadLibrary 在执行 Fork/Join 抽象时让所有核心都处于忙碌状态。

当您使用 Fork/Join 时，您通过调用 Compute 将任务发送到计算池。当您调用Value 获取子计算的结果或调用Await 等待子计算完成并且子计算尚未完成其工作时，Value/Await 将从计算池中获取另一个任务，并且执行它。当这个新任务完成后，它会再次检查子计算是否完成了它的工作，如果没有，它会处理下一个子任务。

OmniThreadLibrary wiki 上进一步描述了此机制。

---

编辑

我不认为 Fork/Join 方法应该被称为“工作窃取”。在 OmniThreadLibrary 实现中，工作项永远不会分配给线程，直到线程开始执行它。而且一旦线程开始执行它，没有人可以窃取它，因为这样做没有任何目的。