本文介绍了为什么这段代码不是异步运行的？的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
据我所知，订阅方法应该是异步的，而运行方法应该是同步的。但这段代码是以同步方式工作的。有人能修好吗？
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Reactive.Linq;
namespace RxExtensionsDemo
{
class Program
{
static void Main(string[] args)
{
IObservable<int> source = Observable.Generate<int, int>(0, i => i < 10000, i => i + 1, i => i * i);
IDisposable subscription = source.Subscribe(x => { Console.WriteLine("Received {0} from source", x); }, ex =>
{
Console.WriteLine("Error occured");
}, () =>
{
Console.WriteLine("Source said there are no more messages to follow");
});
Console.WriteLine("Asynchronous");
Console.ReadKey();
}
}
}
我总是看到异步写入控制台的末尾。
推荐答案
默认Observable.Generate使用Scheduler.CurrentThread。但是，您可以指定不同的调度程序以获得所需的异步行为：
IObservable<int> source = Observable.Generate<int, int>(
0,
i => i < 10000,
i => i + 1,
i => i * i,
Scheduler.NewThread
);
Scheduler类位于System.Reactive.Concurrency命名空间中。
其他可能的异步预定义计划程序包括Scheduler.TaskPool和Scheduler.ThreadPool。
这篇关于为什么这段代码不是异步运行的？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！