我写了个中间件就是干这种事。数据源和处理函数作为你自己的插件插进来。
插件有标准接口。工作内容你随便。
【 在 ylh0315 的大作中提到: 】
: 分配线程每批读1000组ab，发到myfunc线程池的一个线程，这个线程串行的调用1000次myfunc。
: 再读1000组分配给下一个线程。线程都满了等待。谁干完了唤醒分配器再次取得数据。这样可以减小线程切换开销。
: 1000组切换一次。
: ...................
--
FROM 221.221.53.*