CharmPy CharmPy 介绍
CharmPy
CharmPy 是一个通用的分布式并行编程框架,具有简单而强大的 API ,基于可迁移的 Python 对象和远程方法调用; 构建于自适应 C ++
运行时系统之上,提供速度、可扩展性和动态负载平衡。
CharmPy 允许开发从笔记本电脑到超级计算机的并行应用程序。
简单示例:
from charmpy import charm, Chare, Group, Reducerfrom math import piimport timeclass Worker(Chare): def work(self, n_steps, pi_future): h = 1.0 / n_steps s = 0.0 for i in range(self.thisIndex, n_steps, charm.numPes()): x = h * (i + 0.5) s += 4.0 / (1.0 + x**2) # perform a reduction among members of the group, sending the result to the future self.contribute(s * h, Reducer.sum, pi_future)def main(args): n_steps = 1000 if len(args) > 1: n_steps = int(args[1]) mypi = charm.createFuture() workers = Group(Worker) # create one instance of Worker on every processor t0 = time.time() workers.work(n_steps, mypi) # invoke 'work' method on every worker print('Approximated value of pi is:', mypi.get(), # 'get' blocks until result arrives 'Error is', abs(mypi.get() - pi), 'Elapsed time=', time.time() - t0) charm.exit() charm.start(main)
CharmPy CharmPy 官网
https://github.com/UIUC-PPL/charmpy
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。