スレッドAで信号を送り、返答があったときにスレッドＢを起動、スレッドＡの信号のデータを初期化する方法

質問

VC6.0で開発しています。
今、次のような処理をどうすればよいか悩んでいます。ヒントになる回答を頂けたら幸いです。

データをやり取りする際、どのような処理を行うか命令するもの（以下、命令Ａ）と、命令された通りのデータを送るもの（以下、送信Ｂ）、そして、ＡとＢの通信部分を担うもの（以下、通信Ｃ）があります。

データのやりとりは、マルチスレッドで行っています。
データをやりとりするために、スレッドが通信Ｃ上で２つ起動しています。１つ目のスレッド（以下、スレッドＡ）は、送信Ｂが命令Ａから送られる特定のデータ（以下、データＡ）を受け取れるかをどうかの信号を、命令Ａに送るためのものです。２つ目のスレッド（以下、スレッドＢ）は、データＡを通信Ｃが受け取り、送信Ｂに渡すときに起動するスレッドです。

スレッドＡで、送信Ｂから命令Ａへ、受信の準備ができたことを伝える信号が送られます。その後、命令ＡよりデータＡが送られ、通信ＣでスレッドＢが起動するのですが、データＡを通信Ｃで受信したとき、スレッドＡで送っている信号を初期化しなければいけません。

データＡを受信したときにはスレッドＢが起動しますので、スレッドＡとスレッドＢの間での処理ということになります。

スレッド処理について、まだまだ不勉強なのですが、よいアイディアがあれば教えてください。
よろしくお願いします。

回答No.4

zwi · ベストアンサー

アプリ毎に整理してみました。分からないところは想像で書いています。

--命令Ａ--
(1)「命令Ａ→通信Ｃ」のファイルを作成。「送信Ｂが送信Ａに対して、データの要求をしているのかを判別するデータを送信しろ」を送る。
(2)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを監視。「命令Ａにデータ要求」が書き込まれるの待つ。
(3)「命令Ａ→通信Ｃ」のファイル２を作成。「送信Ｂの要求データ」を作成する。
(4)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを監視。「送信Ｂはデータの要求をしていない」に書き換わるの待つ。
(5)(1)に戻る。

--送信Ｂ--
(1)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを監視。「送信Ｂが命令Ａに対して、データの要求があるか」が書き込まれるのを待つ。
(2)「送信Ｂ→通信Ｃ」のファイルを作成して、「送信Ｂが命令Ａに対して、データの要求がある」を書き込む。
(3)「通信Ｃ→送信Ｂ」のファイルが作成されるのを待つ。
(4)ファイルを読んで、データを何らかの手段で送信。
(5)(1)に戻る。

--通信Ｃ--
(1)「命令Ａ→通信Ｃ」のファイルが作成されるを待つ。
(2)スレッド１を起動する。
(3)「送信Ｂ→通信Ｃ」のファイルが作成されるのを待つ。
(4)スレッド１に(3)に進むよう指令を出す。
(5)「送信Ｂ→通信Ｃ」のファイルを削除する。
(6)「命令Ａ→通信Ｃ」のファイル２が作成されたことを検出。
(7)スレッド２を起動する。
(8)このあと？？？

・スレッド１
(1)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを作成。「送信Ｂが命令Ａに対して、データの要求があるか」を書き込む。
(2)何らかの指令があるまで(1)を繰り返す。
(3)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを書き換え。「命令Ａにデータ要求」に書き換える。
(4)何らかの指令があるまで(3)を繰り返す。
(5)「通信Ｃ→送信Ｂ、命令Ａ」のファイルを書き換え。「送信Ｂはデータの要求をしていない」に書き換える。
(6)「命令Ａ→通信Ｃ」のファイルを削除する。
(7)スレッドを終了する。

・スレッド２
(1)スレッド１に対して、指令を送り(5)に移行するように促す。
(2)「命令Ａ→通信Ｃ」のファイル２を読み込み、「通信Ｃ→送信Ｂ」のファイルを作成する。コピー後「命令Ａ→通信Ｃ」のファイル２は削除する。
(3)スレッドを終了する。

勘違いがあったら訂正をお願いします。

全体として問題を感じたので何点か上げます。
・ファイル作成を条件に動いている所があるが、ファイル内容が全部書き出されていないうちに動き出してしまわないか？
・必要な動作に対してやっていることが複雑である。処理の起点はなぜ送信Ｂの要求から始まらないのか？命令Ａから始まる理由は？
・ファイルの後始末が不明確。
・スレッド１の処理で、何度もファイルを書き換える理由は？
・命令Ａと送信Ｂが通信していれば作れそうな気がする処理で、通信Ｃが必要な理由が分からない。

シンプルにするとしたら、こんな感じには出来ないのでしょうか？
一応命令Ａを起点にしています。スレッドがなくなってしまうので、このアプリの構成がスレッドの勉強のためだったら申し訳ない！

--命令Ａ--
(1)送信Ｂにメッセージで要求がないか問い合わせる。
(2)送信Ｂの返事を待つ。
(3)送信要求なら、ファイルを作成する。送信不要なら(1)に戻る。
(4)送信Ｂにメッセージでファイルが出来たことを知らせる。
(5)送信Ｂの返事を待つ。
(6)(1)に戻る。

--送信Ｂ--
(1)命令Ａから要求の問い合わせを待つ。
(2)命令Ａにメッセージで要求の有無を送信。
(3)要求無しなら(1)に戻る。
(4)命令Ａからファイルの完成メッセージが届くのを待つ。
(5)ファイルを読んで何らかの方法で送信する。
(6)ファイルを削除する。
(7)命令Ａにメッセージで送信が完了したことを知らせる。
(8)(1)に戻る。

相互の通信にはWindowsAPIのPostMessageを使用する予定です。
ただし、両方のアプリにhWndが必要なので両方ともウィンドアプリである必要があります。
http://yokohama.cool.ne.jp/chokuto/urawaza/api/PostMessage.html

お礼

返信が遅くなり申し訳ありません。

こちらの方でいろいろ考えた結果、２つのスレッドで考えるより、一つのスレッドで工夫した方がよいということになりました。

zwiさんには、私の分かりづらい説明に付き合っていただいて、ありがとうございました。

回答No.3

zwi

すいません。今読んでところなのですが。
>３．送信Ｂが、データを要求します。
これって、どうやって伝えていますか？

回答No.2

zwi

すいません、まだ複雑でした(^^ゞ
問題なのは、データの流れがいまいち掴めないことです。
流れの順番で書いてもらえませんか？
私なりに分かっていることを想像を交えて書くと。
(1)「通信Ｃ」のスレッド「通信Ｃから命令Ａへ」が命令Ａへの通信ファイルで「送信Ｂがあるデータの送信を命令Ａに要求している」を書き込む。
(2)「命令Ａ」が（１）の指令を見て送信Ｂに送るデータファイルを作成する？
(3)「通信Ｃ」のスレッド「？？？」が「命令Ａ」が作成したデータファイルを発見して「送信Ｂ」に「送信Ｂで送信してほしいファイルがあるよ」という意味のファイルを作成する。
(4)「送信Ｂ」は、「送信Ｂで送信してほしいファイルがあるよ」を見つけたら「命令Ａ」の作ったファイルをなんらかの通信で何処かに送出する。
(5)送信処理の後始末「信号データの初期化」を行う。

って事でしょうか？(1)の前のデータ送信の起点がよく分からないのですが、どのプログラムが送信を要求しているのでしょうか？送信Ｂです？
印象としては、妙に複雑なことをしている気がします。もっとシンプルに作れそうな感じがするのですが、とりあえず流れが分からないとアドバイスできないので、詳細にお願いします。

補足

すいません。補足します。

１．命令Ａが、命令Ａから通信Ｃへ「送信Ｂが送信Ａに対して、データの要求をしているのかを判別するデータを送信しろ」という命令を保存したファイルを共有ディレクトリに保存します。

２．通信Ｃが「１．」のファイルのデータを読み込み、送信Ｂが命令Ａに対して、あるデータの送信を要求しているかどうかを示すデータを共有ディレクトリに保存します。「１．」で保存したファイルとは別のファイルに一定周期で上書き保存を繰り返します。この処理のために、スレッドが一つ起動します。命令Ａは、このファイルを監視して、常にデータをチェックしています。

３．送信Ｂが、データを要求します。

４．通信Ｃが、送信Ｂがデータを要求していることを示すデータを、「２．」で保存したファイルに書き込みます。今後は、初期化されるまで、データ要求を意味するデータを保存し続けます。

５．命令Ａが、データ要求を意味するデータがきたことを検出します。

６．命令Ａが、要求されたデータを書き込んだファイルを、共有ディレクトリに保存します。

７．通信Ｃが「６．」で保存されたファイルを検出し、データを読み込み、送信Ｂにデータが送られます。この処理のために「２．」とは別のスレッドが一つ起動します。

８．「７．」のスレッドが起動すると同時に、「２．」で起動したスレッドでは、ファイルに保存するデータを「送信Ｂはデータの要求をしていない」という意味のデータを保存するようにします。つまり初期化です。

こういった感じなのですが、うまく伝わったでしょうか？
回答をよろしくお願いします。

回答No.1

zwi

ごめんなさい。説明が良くわかりません。他に返答がないのも、それが原因だと思います。命令ＡとかスレッドＡとか？？？です。
どこまでが１つのプログラムなのか、関数の単位はどこまでか、Ａ，Ｂ，Ｃ間ではデータをどうやって受け渡しているのかなど疑問がいっぱいです。そもそも信号って、signalのこと？

で、状況を整理したいと思います。
やっていることの細かい説明はおいておいて、何をやりたいかとスレッド化している理由を説明してもらえないでしょうか。
信号のデータを初期化するという言葉の意味も。

補足

すみません。質問が大雑把＋内容に抜けが多すぎたようです・・・（反省）

データは、ファイルでやりとりしています。
共有のディレクトリがあり、そこにファイルが保存されます。ファイルデータを読み込むのは、命令Ａ、通信Ｃと名前をつけたアプリケーションなのですが、ファイルの種類によって、どちらがデータを読み込むかが決まります。
例えば、拡張子がAAAとついたファイルなら、通信Ｃがディレクトリに保存し、命令Ａが読み込むといった感じです。

１．スレッド化している理由
命令Ａ、送信Ｂ，通信Ｃそれぞれが、一つのアプリケーションです。スレッドは通信Ｃで作成されます。通信Ｃの中の一つのクラスが共有ディレクトリにファイルが保存されたかを監視しています。ファイルが保存されると、このクラスがファイルを読み取り、そのデータに対応した関数を実行します。この実行される関数が、それぞれスレッドとなります。データごとに処理を行う必要があるので、マルチスレッドで処理しています。

２．信号データの初期化
一つのスレッド処理で、通信Ｃから命令Ａに対して、「送信Ｂがあるデータの送信を命令Ａに要求している」かどうかを意味するデータを、共有ディレクトリに保存し続けています。
信号データの初期化とは、送信Ｂが、命令Ａからのデータを通信Ｃを経由して受け取ったあと、共有ディレクトリに保存するデータを、「現在、送信Ｂはデータの要求を行っていない」という意味のデータに変更するということです。

３．何をやりたいのか
「信号」データを保存し続けている処理と、データを受信する処理は別スレッドで処理されています。
「信号の初期化」を行うタイミングは命令Ａが共有ディレクトリにファイルを保存し、これを通信Ｃが検出し、送信Ｂにこのファイルのデータを送るスレッドを起動したときです。
別々のスレッド間での処理になるので、このタイミングで、どう「信号」データの初期化を行えばよいかで悩んでいます。

長々と書いてしまいました。zwiさんが知りたいことに対してきちんと回答できているか不安ですが、回答をよろしくお願いします。