Jug 1.6.1 发布,基于任务的并行处理框架 - 开源中国社区
Float_left Icon_close
Jug 1.6.1 发布,基于任务的并行处理框架
王练 2017年08月31日

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

王练 王练 发布于2017年08月31日 收藏 10

Jug 1.6.1 已发布,该版本修复了 shell 中的 'invalidate()' 的 bug 。

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

更新日志列表

示例:

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)

下载地址:

本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 开源中国社区 [http://www.oschina.net]
本文标题:Jug 1.6.1 发布,基于任务的并行处理框架
分享
评论(1)
最新评论
0
这个东西是不是所谓的rpc
顶部