Haskell框架,用于并行化非线程安全的C++库

Question

我有一个闭源非线程安全的C++共享库,它提供了一个函数f :: ByteString - > ByteString.此功能的运行时间可能介于一秒到几个小时之间.

我正在寻找一种方法将计算分配到多个核心/服务器(SIMD).

简而言之,我正在寻找一个提供功能的框架

    g :: Strategy b -> (a -> b) -> a -> b

提升一个只能被顺序调用到一个函数的函数,该函数的行为类似于Haskell中的任何其他纯函数.

例如,我希望能够写:

    parMap rwhnf f args -- will not work

由于f通过FFI在非线程安全的lib中调用C函数,因此不起作用.因此,我可以用函数g替换函数f,函数g保存作业队列并将任务分派给N个单独的进程.这些进程可以在本地运行或分发:

    parMap rwhnf g args -- should works

我已经研究过的潜在框架是

MPI:客户端(Haskell)< - MPI - >代理(C++)< - MPI - >工作者(C++)< - > Lib(C++)
ZeroMQ:客户端(Haskell)< - ZeroMQ - > Broker(C++)< - ZeroMQ - > Worker(C++)< - > Lib(C++)
Cloud Haskell:客户端(Haskell)< - CloudHaskell - > Worker(Haskell)< - FFI - > Lib(C++)
Gearman的
Erlang:Client(Haskell)< - Erlang - > Broker(Erlang)< - Erlang C Node - > Worker(C++)

每种方法都有优点和缺点.

MPI将产生许多安全问题,并且是一个非常重量级的解决方案.
ZeroMQ是一个很好的解决方案,但需要我自己编写代理/负载均衡器等(特别是获得正确的可靠性并非易事).
CloudHaskell看起来不太成熟.
Gearman不能在Windows上运行,也没有Haskell绑定.我知道java-gearman-service,但它远不如C守护进程成熟,还有其他一些问题(例如没有doc,如果一段时间内没有任务传入,则关闭等等).
与1类似,需要使用第三种语言.

谢谢!