前提・実現したいこと

async/awaitなど最新？C#の技術を使ってみたいのですが、イベントを待って戻り値を返すI/Fのある部分をasync/awaitで表現できませんでした。
いろいろ考えた結果、自分では下のソースのような、Monitorを使った同期機構でしか実現できなかったのですが、もっといい方法があれば教えてください。

下のソースではMyReader.Read()が該当箇所です。Readerインターフェースを実装しており、ただただ、同期I/Oで読んだ結果を返すI/Fです。
このI/Fを実装し、外からイベントで渡されてくるデータを返したいのです。同期I/Oなのでブロックする必要があり、要求されたデータが来るまで待つ必要があります。ここをなんとかawaitで実現したいのですが、いい方法を思いつきませんでした。

なお、EventHolder/Readerの形はいじれないので、ご注意ください。
また主旨に関係ないご指摘も、気づいたことは何でも言って頂けると嬉しいです。

該当のソースコード

C#
1using System;
2using System.Collections.Generic;
3using System.Threading;
4using System.Threading.Tasks;
5
6namespace EventAsyncAwait
7{
8    interface Reader
9    {
10        int Read();
11    }
12
13    class MyEventArgs
14    {
15        public int val { get; set; }
16    }
17
18    class MyReader : Reader
19    {
20        List<int> buffer = new List<int>();
21
22        public int Read()
23        {
24            int result = 0;
25            lock (buffer)
26            {
27                while (buffer.Count == 0)
28                    Monitor.Wait(buffer);
29                result = buffer[0];
30                buffer.RemoveAt(0);
31            }
32            return result;
33        }
34
35        public MyReader(EventHolder parent)
36        {
37            parent.Event += (object sender, MyEventArgs e) =>
38            {
39                lock (buffer)
40                {
41                    buffer.Add(e.val);
42                    Monitor.PulseAll(buffer);
43                }
44            };
45        }
46    }
47
48    class EventHolder
49    {
50        public event EventHandler<MyEventArgs> Event;
51
52        public void Fire(int v)
53        {
54            Event(this, new MyEventArgs() { val = v });
55        }
56    }
57
58    class Program
59    {
60        static EventHolder holder = new EventHolder();
61
62        static void Main(string[] args)
63        {
64            MyReader reader = new MyReader(holder);
65            Task.Run(async () =>
66            {
67                await Task.Delay(3000);
68                holder.Fire(5);
69            });
70            Console.WriteLine(reader.Read());
71        }
72    }
73}

※質問しておいて何ですが、本日反応できるのは夕方くらいからになります。

退会済みユーザー

2019/02/09 23:57

コンソールアプリだから期待通りに動かないってことではありませんか？つまり、Main は非同期で実行される部分の完了を待たないで勝手に走っていって終わってしまうという。

wwbQzhMkhhgEmhU

2019/02/10 04:25

コンソールアプリとかは関係ありません。勝手に走っていってしまってるわけでもないです。ちゃんとブロックして待っていますよ。今、3秒のディレイを入れていますが、このディレイは1分でも2分でも待っています。

pepperleaf

2019/02/10 05:03 編集

コンソールプログラムで、 Task.Run(async () => { await Task.Delay(3000); Console.WriteLine("Wake up!\n"); }); Console.WriteLine("End of Prog\n"); // ここで、プログラム終了としたら、"Wake up!" の文字列、出ませんが、、、。もっとも、最後に、Console.ReadKey(); で入力待ちにしたら、出た。 reader.Read(); で待っているということでしょうか。 Task.Run()の戻り値から、Taskの終了を確認するようにすべきではないでしょうか?

wwbQzhMkhhgEmhU

2019/02/10 05:03

はい、ロックしてモニタで待ってますよね？

wwbQzhMkhhgEmhU

2019/02/10 05:06

Task.Run()の戻り値からではなく、Reader.Read()の実装をしたいんですよ。。。

tamoto

2019/02/10 05:45

要件の確認をさせてください。このイベントは「1回きり」発動することを想定したものですか？それとも、複数回発動する、「ストリーム」を想定していますか？

wwbQzhMkhhgEmhU

2019/02/10 05:55

最終的には複数回だけど、1回きりの方法すら思いついていないので、まずは1回きりでも大丈夫、という意味で、ここでは1回しか待っていません。

行動規範の内容に同意します

回答4件

他にも方法はあるでしょうが、IObservable<T> を使ってください。

Reactive Extensions を使うと簡単です。これを使うには NuGet で System.Reactive をインストールする必要があります。

追記

例えば Reactive Extensions を使ってボタンのクリックイベントを受け取るには次のようにします。

C#
1using System;
2using System.Reactive.Linq;
3using System.Windows.Forms;
4
5namespace WindowsFormsApp1
6{
7    public partial class Form1 : Form
8	{
9		public Form1()
10		{
11			InitializeComponent();
12            Observable
13                .FromEventPattern<EventArgs>(button1, nameof(Button.Click))
14                .Subscribe(_ => MessageBox.Show("クリックされた！"));
15		}
16	}
17}

追記

ボタンを二つ貼り付け、button2 のイベントハンドラを次のように書き換えてください。
そして button2 を押した後、button1 を押すとメッセージが表示されます。

C#
1private async void button2_Click(object sender, EventArgs e)
2{
3    var task = Observable
4        .FromEventPattern<EventArgs>(button1, nameof(Button.Click))
5        .Take(1)
6        .ToTask();
7    await task;
8    MessageBox.Show("button1 が押されました");
9}

投稿2019/02/09 23:51

質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう！

前提・実現したいこと

該当のソースコード

追記

追記

関連した質問