Jug是一个基于任务的并行处理框架,采用Python编写,可用来在不同的机器上运行同一个任务,使用NFS做文件系统的通讯。
示例代码:
fromjugimportTaskGeneratorfromtimeimportsleep@TaskGeneratordefis_prime(n):sleep(1.)forjinxrange(2,n-1):if(n%j)==0:returnFalsereturnTrueprimes100=map(is_prime,xrange(2,101))Jug是一个基于任务的并行处理框架,采用Python编写,可用来在不同的机器上运行同一个任务,使用NFS做文件系统的通讯。
示例代码:
fromjugimportTaskGeneratorfromtimeimportsleep@TaskGeneratordefis_prime(n):sleep(1.)forjinxrange(2,n-1):if(n%j)==0:returnFalsereturnTrueprimes100=map(is_prime,xrange(2,101))
评论