UIとは別に非同期で無限ループするクラスの作成方法

Question

UIとは別に非同期で無限ループするクラスの作成方法

お世話になっております。
WFPアプリケーションにて、サーバーから値を取得して、処理を行うクラスを作成したいと思っております。
基本的に、アプリが起動してから終了するまでの期間中動作させることを想定しております。

以下のようにしてしまうと、UI側は固まってしまうと思います

Class Recv
{
    Recv()
    {
        Loop();
    }
    void Loop()
    {
        while(true)
        {
            int a = GetValue(); // サーバーから値をもらうと仮定
            a += 10;
            Console.WriteLine(a);
            Thread.Sleep(1000);
        }
    }
}

// UI側から
Recv r = new Recv();

質問
下記のような書き方を行えばUIが固まることはないのですが、問題ないでしょうか。
最適な方法がございましたら、よろしくお願いいたします。

Task.Run(() => Recv r = new Recv());

Recv()
{
    Task.Run(() => Loop());
}

Answer 1

こんにちは。

既に解決しているようですが、ちょっと細かい指摘だけしてみます。
UIとは別に無限ループさせるだけなら他回答者さんのやり方で全く問題なく動きます。が、Loop()メソッド自体が同期的に無限ループしているため、「常に1本スレッドを握りしめて継続処理」という形になっているのが気になります。
非同期メソッドを活用することで、ループ処理を定期的なスケジューリングとして実装することができ、資源効率を改善できます。

async void Loop()
{
    while(true)
    {
        int a = GetValue(); // サーバーから値をもらうと仮定
        // int a = await GetValueAsync().ConfigureAwait(false); // 普通は外から値を取得(IO)するなら非同期メソッドになるのでは？
        a += 10;
        Console.WriteLine(a);
        await Task.Delay(1000).ConfigureAwait(false);
    }
}

// 使う時はただ呼ぶだけ
Recv()
{
    Loop();
}

進行状態等を一切管理しない無限ループだったので戻り値をvoidにしていますが、仮にGetValue()が例外を吐いたりするととても面倒なことになるので、Taskを返すようにしてエラーハンドリング等を実装したほうが良いです。

Comments

[kawauso]

こんにちは。回答ありがとうございます。
非常に勉強になりました。

サーバー側から送られてくる値を取得するところは[こちらのZeroMQ](https://github.com/zeromq/clrzmq4)を使用しています。

```c#
using (var context = new ZContext())
using (var requester = new ZSocket(context, ZSocketType.REQ))
{
requester.Connect("tcp://127.0.0.1:5555");
while(true)
{
var a = requester.ReceiveFrame(); // (1)
}
}
```
上記のように書くことで、N秒ごとにサーバーから値が送られてくるとすると、(1)がN秒ごとに呼ばれているようです。
```ReceiveFrameAsync();```のようなメソッドは見当たりませんでした。
このような場合「常に1本スレッドを握りしめて継続処理」されてしまっているんでしょうか？

[tamoto]

なるほど、見た感じですが、ReceiveFrame()メソッドは「値が送られてくるまでスレッドをブロックして待機」する同期メソッドのように見えますね。これは非同期アクセス用のAPIが提供されていないのであれば、同期メソッドを利用するしかないことになります。
ただし、このコメントのコード例は「受信側で常に1本のスレッドを専有してサーバからのデータの『push』を待機」するものなので、質問のコードのような「一定時間ごとにサーバからデータを『fetch』」するものとは意味合いが異なります。

[kawauso]

ありがとうございます。もう少し勉強してみたいと思います。

Answer 2

Task.Run(() => Recv r = new Recv());

このTask.Runはいらないです。

Recvの中でTask.Run()してるのでわざわざ Recvを別スレッドで実行する意味はありません。

Recv r = new Recv();

Recv()
{
    Task.Run(() => Loop());
}

Comments

[kawauso]

回答、ご指摘ありがとうございます。

Answer 3

こんにちは。

特に問題ないのではないでしょうか。

あとは通常の非同期処理の注意点を気にすれば良いだけだと思います。

• UIを操作するときは、UIスレッドで。
• 共有リソースを扱う場合はスレッドセーフを。

Comments

[kawauso]

回答ありがとうございます。
非同期処理の注意点に気をつけて実装していきたいと思います。