Jam*_*hes 5 .net reactive-programming system.reactive
我正在使用.Net3.5SP1中的Rx并尝试101 Rx示例.我正在尝试第一个示例(开始 - 异步运行代码),但它似乎并没有实际异步运行.例如,
Console.WriteLine("[Creating]");
var o = Observable.Start(() =>
{
Console.WriteLine("Calculating...");
Thread.Sleep(3000);
Console.WriteLine("Done.");
});
Console.WriteLine("[Created]");
Console.WriteLine("[Starting]");
o.First(); // subscribe and wait for completion of background operation
Console.WriteLine("[Started]");
Run Code Online (Sandbox Code Playgroud)
输出
[Creating]
[Created]
[Starting]
Calculating...
<...3 Second Wait...>
Done.
[Started]
Run Code Online (Sandbox Code Playgroud)
对此有解释吗?难道我做错了什么?这是预期的行为吗?
UPDATE
我本以为会说的
[Creating]
[Created]
[Starting]
Calculating...
[Started]
<...3 Second Wait...>
Done.
Run Code Online (Sandbox Code Playgroud)
但是,当所谓的Asynch调用发生时,主线程被阻塞.
| 归档时间: |
|
| 查看次数: |
521 次 |
| 最近记录: |