DataReader Listener Thread Safety
まだ誰も着手していません。
評価
調査の方向性
まず、提供された再現プログラムを実行し、DataWriter.write および MyListener.on_data_available と並行して DataReader listener のディスパッチを追跡します。その相互作用に関係する 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時間
- マージ済み PR（30日）
- 1
環境構築
このプロジェクトには開発コンテナ、Dockerfile、コントリビューションガイドがありません。まず README を読み、一般的な手順ははじめてのコントリビューションガイドを参照してください。
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- 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"再び着手できるかも このイシューのプルリクエストはマージされずにクローズされました。 オープン
難易度 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
-
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
docling-project/docling-mcp#147 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 80/100
メンテナーはふだん 1 日以内に返信
-
enhancement
難易度 2/5 1〜3時間 初心者へのやさしさ 76/100
autowarefoundation/autoware_carla_scenario#405 ·
メンテナーはふだん 1 日以内に返信
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 79/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
mohitmishra786/readprism#322 ·
メンテナーはふだん 1 日以内に返信