我试图在Python中使用multiprocessing使函数一直在循环中被调用,然后从函数中访问最新的返回值(通过将值存储在LIFO队列中)。
下面是主程序的代码片段
q = Queue.LifoQueue()
while True:
p = multiprocessing.Process(target=myFunc, args = (q))
p.daemon = True
p.start()
if not q.empty():
#do something with q.get()
下面是来自myFunc的代码片段
def myFunc(q):
x
我开始使用节点集群包,很快就发现主服务器和集群之间没有共享数据。让我们以这个例子为例:
var cluster = require('cluster');
var numCPUs = require('os').cpus().length;
var my_array = [];
if(cluster.isMaster) {
for (var i = 0; i < numCPUs && i < 8; i++) {
cluster.fork();
}
my_array.push('te