0

我有一个场景，我创建了一个传递给父线程的取消令牌，我需要将相同的取消令牌传递给子线程。但是当我将取消令牌传递给子线程时，当父调用 Cancel() 时线程不会被取消。

public void main()
{
   CancellationTokenSource cts = new CancellationTokenSource();
   CancellationToken token = cts.Token;
   ChildClass instance = new ChildClass();

   Task.Factory.StartNew(() => 
                Task.Factory.StartNew(() => instance.start(token), token), token);
}

public void cancel()
{
    cts.Cancel();
}

public class ChildClass()
{
    public void start(CancellationToken token)
    {
        ParallelOptions po = new ParallelOptions();
        po.CancellationToken = token;

        Parallel.For(0, 10, i => 
              {"do some processing"}, po, i);
    } 
}

我在父类中创建了一个取消令牌并通过并行选项将其传递给子线程，但是当父类调用 Cancel() 时，Parallel.For 创建的线程不会终止。

是否有传递 CancellationToken 作为参考的概念？

4

1 回答 1

1

您使用 CancellationTokenSource 的方式本身并没有错。你只是不知道任务被取消，因为你没有Wait用来处理TaskCanceledException. 这是什么时候Main：

CancellationTokenSource cts = new CancellationTokenSource();
CancellationToken token = cts.Token;
ChildClass instance = new ChildClass();

var task = Task.Factory.StartNew(() =>
                Task.Factory.StartNew(() => instance.start(token), token), token);
cts.Cancel();
task.Wait();

你会看到异常。

Parallel.For这是一个被取消的完整示例：

internal class Program
{
    private static void Main()
    {
        var cts = new CancellationTokenSource();
        var instance = new ChildClass();

        var task = Task.Factory.StartNew(() =>
                Task.Factory.StartNew(() => instance.start(cts.Token)).Wait());
        cts.Cancel();
        task.Wait();
    }
}

public class ChildClass
{
    public void start(CancellationToken token)
    {
        var parallelOptions = new ParallelOptions {CancellationToken = token};
        try
        {
            Parallel.For(0, 100000, parallelOptions, i =>
            {
                // Do something
            });
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("canceled");
        }
    }
}

输出：

取消

于 2014-08-21T21:42:51.173 回答