为什么这段代码不是异步的?

本文关键字：异步 代码 段代码 为什么 | 更新日期: 2023-09-27 18:08:12

据我所知订阅方法应该是异步的，而运行是同步的。但是这段代码是以同步方式工作的。有人能修好它吗?

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。

相关文章：