如何在取消后启动任务

我有一个带有三个按钮的Windows窗体。一个按钮将条目添加到BlockingCollection。一个开始处理列表，一个停止处理列表。如何在取消后启动任务

我可以添加条目到我的BlockingCollection，当我点击开始，列表被消耗，因为我所期望的。我仍然可以添加新项目并继续消耗。但是，当我单击“停止”按钮时，尽管任务停止，但我无法使用开始按钮再次启动它们。

我在做什么取消任务错误，他们不会重新开始？我已经阅读了无数有关取消任务的内容，但仍然不明白。

任何帮助将是伟大的。这里是代码...

// Blocking list for thread safe queuing 
    private BlockingCollection<QueueItem> ItemList = new BlockingCollection<QueueItem>(); 
    private CancellationTokenSource CancelTokenSource = new CancellationTokenSource(); 
    private int MaxConsumers = 3; 

    // Form initialisation 
    public MainForm() 
    { 
     InitializeComponent(); 
    } 

    // Create an async consumer and add to managed list 
    private void CreateConsumer(int iIdentifier) 
    { 
     Task consumer = Task.Factory.StartNew(() => 
     { 
      foreach (QueueItem item in ItemList.GetConsumingEnumerable()) 
      { 
       Console.WriteLine("Consumer " + iIdentifier.ToString() + ": PROCESSED " + item.DataName); 
       Thread.Sleep(894); 

       if (CancelTokenSource.IsCancellationRequested) 
        break; // Cancel request 
      } 
     }, CancelTokenSource.Token); 
    } 

    // Add a new item to the queue 
    private void buttonAdd_Click(object sender, EventArgs e) 
    { 
     for (int i = 0; i < 10; i++) 
     { 
      Task.Factory.StartNew(() => 
      { 
       // Add an item 
       QueueItem newItem = new QueueItem(RandomString(12)); 

       // Add to blocking queue 
       ItemList.Add(newItem); 
      }); 
     } 
    } 

    // Start button clicked 
    private void buttonStart_Click(object sender, EventArgs e) 
    { 
     buttonStart.Enabled = false; 
     buttonStop.Enabled = true; 

     // Create consumers 
     for (int i = 0; i < MaxConsumers; i++) 
     { 
      CreateConsumer(i); 
     } 
    } 

    // Stop button clicked 
    private void buttonStop_Click(object sender, EventArgs e) 
    { 
     CancelTokenSource.Cancel(); 

     buttonStop.Enabled = false; 
     buttonStart.Enabled = true; 
    } 

    // Generate random number 
    private static Random random = new Random((int)DateTime.Now.Ticks); 
    private string RandomString(int size) 
    { 
     StringBuilder builder = new StringBuilder(); 
     char ch; 
     for (int i = 0; i < size; i++) 
     { 
      ch = Convert.ToChar(Convert.ToInt32(Math.Floor(26 * random.NextDouble() + 65))); 
      builder.Append(ch); 
     } 

     return builder.ToString(); 
    }

来源

2012-08-02 Simon

您重新使用仍然配置为取消的相同取消标记。

因此，在开始新任务时创建一个新标记。

来源

2012-08-02 09:22:44

感谢您的回复。但是，我应该在什么阶段这样做？我如何知道任务已被取消 - 或者在发出Cancel（）命令后无关紧要？ – Simon 2012-08-02 09:35:32

开始新任务时创建一个新的令牌。重置当前令牌将影响尚未取消的任务。 – 2012-08-02 09:37:29

谢谢 - 工作完美。 :) – Simon 2012-08-02 09:43:44

如何在取消后启动任务

回答

相关问题