红联Linux门户
Linux帮助

Jug 1.6.2发布,基于任务的并行处理框架

发布时间:2017-10-27 09:02:12来源:红联作者:baihuo
Jug 1.6.2 已发布,更新如下:

将 return_value 参数添加到 jug_execute

新增 exit_env_vars

Jug 是一个基于任务的并行处理框架,采用 Python 编写,可用来在不同的机器上运行同一个任务,使用 NFS 作为文件系统的通讯。

示例:[code]from time import sleep

from jug import TaskGenerator

@TaskGenerator
def is_prime(n):
sleep(1.)
for j in range(2, n - 1):
if (n % j) == 0:
return False
return True

@TaskGenerator
def count_primes(ps):
return sum(ps)

@TaskGenerator
def write_output(n):
output = open('output.txt', 'wt')
output.write("Found {0} primes <= 100.\n".format(n))
output.close()

primes100 = []
for n in range(2, 101):
primes100.append(is_prime(n))

n_primes = count_primes(primes100)
write_output(n_primes)[/code]软件详情:https://github.com/luispedro/jug/blob/master/ChangeLog

下载地址:https://github.com/luispedro/jug/archive/v1.6.2.zip

来自:开源中国社区
文章评论

共有 0 条评论