問題タブ [dispy]

dispy を使用して Python でコンピューティング クラスターを作成しています。私の使用例の 1 つは、分散プロセスを開始するコンピューティング ノードでプロセスを開始することで、うまく解決できます。そのため、プライマリ スケジューラに SharedJobCluster を実装し、クラスタに送信される関数にも実装しました (一連の分散プロセスを開始する必要があります)。ただし、2 番目の SharedJobCluster が開始されると、コードがハングし、この行を超えません (エラーも表示されません)。

最小限の作業例:

test2.py には以下が含まれます。

参考までに、私は現在、dispyscheduler.py、dispynode、およびこの python コードをすべて同じマシンで実行しています。埋め込み配布タスクを開始しようとする場合を除いて、このセットアップは機能します。

worker.log の出力には「Starting cluster...」が含まれていますが、他には何も含まれていません。

ノードのステータスを確認すると、1 つのジョブを実行していると表示されますが、完了しません。

dispy ページ ( http://dispy.sourceforge.net/ ) でプログラムを実行しようとしていますが、この質問が以前に尋ねられたものと非常に似ていることはわかっています (ポート 51347 は別のプログラムで使用されているようです)。そこにある回答を試してみましたが、問題が解決しないため、重複としてファイルしないでください。netstat を実行したところ、ポート 51347 で実行されているプログラムが見つかりませんでした。

いくつかの異なるポートでプログラムを実行しようとしましたが、localhost IP を使用して実行しようとするたびに、「ポート xxxx は別のプログラムによって使用されているようです」という同じエラーが表示され続けました。別の IP で使用してみましたが、エラーは発生しませんでしたが、コードは単にローカルで実行されるのではなく、その IP からの入力を待ちます。

他の誰かがこの問題を抱えていて、修正を見つけましたか?