DataReader Listener Thread Safety
还没有人认领这个 Issue。
评估
调研方向
首先运行提供的复现程序，并跟踪 DataReader listener dispatch，以及 DataWriter.write 和 MyListener.on_data_available 的执行过程。检查参与该交互的 listener 和 reader 入口点；当示例在不挂起的情况下完成，同时 listener 回调仍按预期运行时，即表示完成。
由索引模型根据 Issue 内容生成。
描述
The following code appears to trigger a deadlock when attempting to use a Listener on a DataReader.
I'm using CycloneDDS commit: d38e63ff8ed5123650beab9bef2b294b56628696: 28 Jun 23
and CycloneDDS Python commit: 7486f5504a988efbd4838b8ecb881d20e34a7644: 25 May 23
and installing the Python library via CYCLONEDDS_HOME=${CYCLONEDDS_HOME} python3 -m pip install /path/to/cyclonedds-python
from concurrent.futures import ThreadPoolExecutor, wait
from dataclasses import dataclass
from time import sleep
from cyclonedds.pub import DataWriter
from cyclonedds.sub import DataReader
from cyclonedds.core import Listener
from cyclonedds.topic import Topic
from cyclonedds.domain import DomainParticipant
from cyclonedds.idl.annotations import key as _key
from cyclonedds.idl import IdlStruct
@dataclass
class KeyedString(IdlStruct, typename="DDS.KeyedString"):
"Represents a key-value string pair"
key: str
value: str
_key("key")
class MyListener(Listener):
def on_data_available(self, _):
print("on_data_available")
for i in range(10):
print(i)
sleep(0.1)
def test_listener():
participant = DomainParticipant()
topic = Topic(domain_participant=participant,
topic_name="foo", data_type=KeyedString)
writer = DataWriter(publisher_or_participant=participant, topic=topic)
_ = DataReader(subscriber_or_participant=participant,
topic=topic, listener=MyListener())
def do_write():
writer.write(
sample=KeyedString("hello", "world"))
with ThreadPoolExecutor(max_workers=2) as thread_pool:
wait([thread_pool.submit(do_write) for _ in range(10)])
if __name__ == '__main__':
test_listener()
Output:
on_data_available
0
(then it just hangs here until I kill the python process)
Setting the DataReader listener to None resolves the deadlock. Is this an issue with the listener (or elsewhere), or am I doing something wrong here?
- 主要语言
- Python
- 星标
- 110
- 派生
- 68
- 平均合并
- 3 天 5 小时
- 30 天内合并 PR
- 1
环境准备
这个项目没有提供开发容器、Dockerfile 或贡献指南，环境需要你自己搭建：先看它的 README，通用步骤见我们的新手贡献指南。
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
eclipse-cyclonedds/cyclonedds-python 的其他 Issue
-
难度 4/5 3-5 天 新手友好度 52/100
-
Generated Python code is not interoperable when a union contains a member called "value"可能重新可做 关联的 PR 已关闭且未合并。 未关闭
难度 3/5 1-2 天 新手友好度 58/100
-
难度 4/5 3-5 天 新手友好度 48/100
-
难度 4/5 3-5 天 新手友好度 45/100
-
难度 4/5 3-5 天 新手友好度 48/100
eclipse-cyclonedds/cyclonedds-python#333 · 1 条评论 ·
查看 eclipse-cyclonedds/cyclonedds-python 的全部 Issue
相似的 Issue
-
resource-submission validation-passed
难度 1/5 1 小时以内 新手友好度 88/100
hesreallyhim/awesome-claude-code#3214 · 1 条评论 ·
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 78/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 68/100
doobidoo/mcp-memory-service#1650 ·
维护者通常 1 天内回复
-
难度 1/5 1-3 小时 新手友好度 82/100
-
难度 2/5 1-3 小时 新手友好度 76/100
ml-explore/mlx-lm#2002 ·
维护者通常 2 天内回复