在不旋转的情况下保持任务活动和所有订阅活动的正确方法是什么？

Question

我在聚合方法实现中有以下 TPL 任务

public abstract class AggregatorBase : IAggregator
{

    public void Start(CancellationToken token)
    {
        var parent = Task.Factory.StartNew(x =>
        {
            Aggregate(token);
        },TaskCreationOptions.LongRunning, token);

        parent.Wait();
    }

    public abstract void Aggregate(CancellationToken ct);
}

我有许多 Observable.Subscription 以以下结尾

   public override void Aggregate(CancellationToken ct)
   {
            this.observables.Subscribe(// Do stuff);
            this.observables.Subscribe(// Do more stuff);

            while (!token.IsCancellationRequested)
            {
                System.Threading.Thread.Sleep(1000)
            }
   }

问题是保持任务活动和所有订阅活动而不旋转的最佳方法是什么？

Answer 1

等待取消令牌的等待句柄：

while ( !token.IsCancellationRequested )
{
    if ( token.WaitHandle.WaitOne( timeout ) )
    {
        // cancelled. Don't have to do anything here, the above while 
        // loop will break now.
    }
    else
    {
        // ''timeout' period elapsed - do some periodic work here.
    }

}

编辑：
如果您没有在此线程上执行任何定期工作，则只需使用不带超时参数的 WaitOne 重载即可。

token.WaitHandle.WaitOne();

这将无限期地等待，直到发出取消令牌信号，然后继续。

编辑2：

我刚刚读到您说您在可观察的订阅中有 while 循环。它应该是在您设置所有可观察量订阅之后，但不是在每个实际订阅回调中（这些订阅将在调用源事件的任何线程或可能的其他线程池线程上运行，而不是在设置订阅的任务线程上运行） ）。