开源 企业版 高校版 私有云 模力方舟 AI 队友
代码拉取完成,页面将自动刷新
捐赠
捐赠前请先登录
扫描微信二维码支付
取消
支付完成
支付提示
将跳转至支付宝完成支付
确定
取消
1 Star 0 Fork 0

严洪/DistributedAlgorithm

加入 Gitee
与超过 1400万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
已有帐号? 立即登录
文件
main
分支 (1)
main
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
项目仓库所选许可证以仓库主分支所使用许可证为准
main
分支 (1)
main
克隆/下载
克隆/下载
提示
下载代码请复制以下命令到终端执行
为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置
初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置
1 生成 RSA 密钥
2 获取 RSA 公钥内容,并配置到 SSH公钥
在 Gitee 上使用 SVN,请访问 使用指南
使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议 配置并使用私人令牌 替代登录密码进行克隆、推送等操作
Username for 'https://gitee.com': userName
Password for 'https://userName@gitee.com': # 私人令牌
main
分支 (1)
main
wave.py 2.46 KB
一键复制 编辑 原始数据 按行查看 历史
严洪 提交于 2024年04月11日 23:42 +08:00 . Adapter mnn cuda
# Corrected simulation of the wave algorithm
class Node:
def __init__(self, node_id):
self.node_id = node_id
self.neighbors = []
self.parent = None
self.received_messages = 0
self.decision_made = False
def add_neighbor(self, neighbor_node):
self.neighbors.append(neighbor_node)
def send_wave(self):
print(f"Node {self.node_id} sends a wave message to its neighbor(s)")
for neighbor in self.neighbors:
neighbor.receive_wave(self)
def receive_wave(self, from_node):
self.received_messages += 1
if not self.parent:
self.parent = from_node
print(f"Node {self.node_id} receives a wave message from Node {from_node.node_id} and assigns it as its parent")
# After receiving wave from its parent, it sends out waves to its other neighbors
for neighbor in self.neighbors:
if neighbor != from_node:
neighbor.receive_wave(self)
def make_decision_and_notify(self):
if not self.decision_made and self.received_messages == len(self.neighbors):
self.decision_made = True
print(f"Node {self.node_id} decides and sends notification to its neighbor(s)")
for neighbor in self.neighbors:
neighbor.receive_notification(self)
def receive_notification(self, from_node):
# Receiving a decision notification from a neighbor
if self.decision_made:
# Already made a decision, just pass on the notification
print(f"Node {self.node_id} receives a notification from Node {from_node.node_id} and halts")
else:
# If not yet made a decision, wait until a decision is made
self.received_messages += 1
if self.received_messages == len(self.neighbors):
self.make_decision_and_notify()
# Initialize nodes
nodes = [Node(i) for i in range(1, 7)]
# Setup neighbors
neighbors = {1: [3], 2: [3], 3: [1, 2, 4], 4: [3, 5, 6], 5: [4], 6: [4]}
for node_id, neighbor_ids in neighbors.items():
node = nodes[node_id - 1]
for neighbor_id in neighbor_ids:
node.add_neighbor(nodes[neighbor_id - 1])
# Start the wave messages from leaf nodes
leaf_nodes = [node for node in nodes if len(node.neighbors) == 1]
for leaf_node in leaf_nodes:
leaf_node.send_wave()
# After waves are sent, each node checks if it can make a decision
for node in nodes:
node.make_decision_and_notify()
Loading...
举报
举报成功
我们将于2个工作日内通过站内信反馈结果给你!
请认真填写举报原因,尽可能描述详细。
请选择举报类型
取消
发送
误判申诉

此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。

如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。

取消
提交

简介

取消

发行版

暂无发行版

贡献者

全部

语言

近期动态

不能加载更多了
编辑仓库简介
简介内容
主页
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/tunmx/DistributedAlgorithm.git
git@gitee.com:tunmx/DistributedAlgorithm.git
tunmx
DistributedAlgorithm
DistributedAlgorithm
main
点此查找更多帮助

搜索帮助

评论
仓库举报
回到顶部
登录提示
该操作需登录 Gitee 帐号,请先登录后再操作。
立即登录
没有帐号,去注册

AltStyle によって変換されたページ (->オリジナル) /