标签：code work .net core nuget 4gl 信息 收信 span 最新版
static void SimpleMessage() { var channel = new Channel<String>(); Task.Run(async () => { await channel.SendAsync("Hello World!"); }); var message = channel.Receive(); Console.WriteLine(message); }
在上面这个例子中，我们在TPL Task中通过信道发送消息。主线程通过Receive接收消息。这里，由于我们的SimpleMessage方法不是一个async方法，我们不能使用ReceiveAsync来接收消息。
static void ChannelSychronization() { var channel = new Channel<bool>(); Task.Run(async () => { Console.Write("Working..."); await Task.Delay(1000); Console.WriteLine("done"); await channel.SendAsync(true); }); channel.ReceiveAsync().Wait(); }
在这个例子中，主线程被ReceiveAsync堵塞，当TPL Task发送消息后，程序才结束。
static void Select() { var channel1 = new Channel<String>(); var channel2 = new Channel<String>(); Task.Run(async () => { await Task.Delay(1000); await channel1.SendAsync("one"); }); Task.Run(async () => { await Task.Delay(2000); await channel1.SendAsync("two"); }); for (var i = 0; i < 2; i++) { new Select() .OnReceive(channel1, msg1 => { Console.WriteLine("received " + msg1); }) .OnReceive(channel2, msg2 => { Console.WriteLine("received " + msg2); }).ExecuteAsync().Wait(); } }
在上面的例子中，我们通过Select同时从两个信道channel1和channel2接收信息。
标签：code work .net core nuget 4gl 信息 收信 span 最新版
原文地址：http://www.cnblogs.com/mcai4gl2/p/6790640.html
