Как отменить поток после таймаута

Question

У меня есть многопоточное приложение, и я использую this для управления процессами no.of (2). Я хочу обрабатывать файлы только для указанного времени. Ниже мой подход. Я получаю Отменен CancellationTokenSource. ошибка.

Если я не рассылаю cts.Dispose();, тогда процесс не сутулится через 10 секунд. Он продолжает обрабатывать до 1000. Может ли кто-нибудь мне помочь здесь.

Примечание: У меня 1000 файлов. Требование - это файлы процесса в течение заданного времени (10 секунд) путем управления количеством процессов (2) и сном между ними (некоторые x мс).

Ниже мой код

class Program 
{ 
    static void Main(string[] args) 
    { 
     try 
     { 
      LimitedConcurrencyLevelTaskScheduler lcts = new LimitedConcurrencyLevelTaskScheduler(2); 
      List<Task> tasks = new List<Task>(); 
      TaskFactory factory = new TaskFactory(lcts); 
      CancellationTokenSource cts = new CancellationTokenSource(); 

      for (int i = 0; i < 1000; i++) 
      { 
       int i1 = i; 
       var t = factory.StartNew(() => 
       { 
        if (cts != null) 
         Console.WriteLine("{0} --- {1}", i1, GetGuid(cts.Token)); 
       }, cts.Token); 

       tasks.Add(t); 
      } 

      Task.WaitAll(tasks.ToArray(), 10000, cts.Token); 
      cts.Dispose(); 
      Console.WriteLine("\n\nSuccessful completion."); 
      Console.ReadLine(); 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex.Message); 
     } 
    } 

    private static Guid GetGuid(CancellationToken cancelToken) 
    { 
     if (cancelToken.IsCancellationRequested) 
     { 
      return Guid.Empty; 
     } 
     Thread.Sleep(TimeSpan.FromSeconds(1)); 
     return Guid.NewGuid(); 
    } 
} 

Answer 1

Что вы можете сделать, это можно выполнить задачу, которая изменит ваше состояние Отмена токен отменен после того, как некоторое время.

Как это:

class Program 
{ 
    public static void ProcessFiles(CancellationToken cts) 
    {    
     try 
     {     
      LimitedConcurrencyLevelTaskScheduler lcts = new LimitedConcurrencyLevelTaskScheduler(2); 
      List<Task> tasks = new List<Task>(); 
      TaskFactory factory = new TaskFactory(lcts);     

      for (int i = 0; i < 1000; i++) 
      { 
       int i1 = i; 
       var t = factory.StartNew(() => 
       { 
        if (cts != null) Console.WriteLine("{0} --- {1}", i1, GetGuid()); 
       }, cts); 

       tasks.Add(t); 
      } 

      Task.WaitAll(tasks.ToArray()); 

      Console.WriteLine("\n\nSuccessful completion."); 
      Console.ReadLine(); 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex.Message); 
     } 
    } 

    static void Main(string[] args) 
    { 
     CancellationTokenSource cts = new CancellationTokenSource(); 
     Task.Factory.StartNew(() => { Thread.Sleep(10000); cts.Cancel(); }); 
     ProcessFiles(cts.Token); 
     Console.ReadKey(); 
    } 

    private static Guid GetGuid() 
    { 
     Thread.Sleep(TimeSpan.FromSeconds(1)); 
     return Guid.NewGuid(); 
    } 
}