7

Например, есть несколько практически одинаковых потоков, которые могут длиться до бесконечности

инициализация:

 ParameterizedThreadStart pts = new ParameterizedThreadStart(runMethod);
 Thread t = new Thread(pts);            
 t.Start(values);

поток:

 void run(object p)
 {
      // нужен поток, который повторяет одно и то же с некоторой переодичностью, поэтому так:

      while(true)
      {
           // что-то делаем
           doAnything(p);

           Thread.Sleep(60000);
      }
 }

Вопрос в том, как их адекватно прервать? Было бы здорово, если их прервать можно было прервать пока они спят или хотя бы после doAnything();

можно в основном потоке сделать что-то вроде

 Thread t = new Thread(pts);            
 t.Start(values);
 ...
 t.Abort();

но я не уверен, что в потоке не прервется какая-то важная операция - загрузка/удаление/обработка файла или транзакция какая-то незакомитится

5
  • 1
    Кажется, этот вопрос тут уже несколько раз задавался - но те разы были не настолько "чистыми", в них примешивались другие проблемы. 13 окт 2016 в 8:18
  • 1
  • @andreycha я понимаю, что там вы ответили примерно то же самое что и я - но вопросы-то разные! Здесь вопрос более общий. 13 окт 2016 в 9:47
  • @andreycha потоки нужно останавливать не только перед запуском нового экземпляра, но и, к примеру, перед остановкой сервиса. 13 окт 2016 в 9:48
  • Может не в тему, но я не понимаю зачем это все, если на дворе 2016 год C# 6.0 , .Net 4.6 и существует TPL и async/await ?
    – Bulson
    13 окт 2016 в 15:24

2 ответа 2

10

Красивее всего это делается через механизм CancellationToken. Этот механизм специально создан для передачи сообщений об остановки и отмене между потоками:

void run(object p)
{
  var ct = (CancellationToken)p;

  do
  {
       // что-то делаем
       doAnything(p);
  } while (!ct.IsCancellationRequested && !ct.WaitHandle.WaitOne(60000));
}

Здесь я использую ожидание на событии как прерываемую альтернативу Thread.Sleep. Если ожидание успешно - значит, поток надо останавливать. Если неуспешно (тайм-аут ожидания) - значит, можно продолжать работу.

Перед ожиданием я проверяю IsCancellationRequested, чтобы не создавать событие ядра когда этого не требуется.

Создание такого потока:

using (var cts = new CancellationTokenSource()) {
    new Thread(run).Start(cts.Token);
    ...
    cts.Cancel();
}

Также вместо потока можно использовать задачу (Task.Run). В таком случае для ожидания лучше использовать Task.Delay, это позволит обойтись вовсе без объектов ядра:

async Task run(CancellationToken ct)
{
  do
  {
       // что-то делаем
       doAnything(p);

       await Task.Delay(60000, ct);
  } while (!ct.IsCancellationRequested);
}

Task.Run(() => run(cts.Token));

Бонусом к использованию CancellationToken идет возможность передачи ct дальше в doAnything - благодаря чему вы можете тонко выбирать, в какие моменты допустимо прерывание обработки.

Если вы будете использовать асинхронный вариант - то практически все асинхронные функции стандартной библиотеки также умеют принимать CancellationToken, что позволяет безопасно прервать любую долгую операцию, если вы того пожелаете.


В более старых рантаймах, где механизма CancellationToken нет, для той же цели можно использовать ManualResetEvent. Принцип тот же - вместо вызова Thread.Sleep ждем на событии и проверяем результат.

3
  • С наличием в языке лямбд необходимость в передаче объекта в поток и каста в CancellationToken по идее не так велика. Хотя ваш код объявлен как код для старой версии языка, так что...
    – VladD
    13 окт 2016 в 14:50
  • @VladD честно говоря, не вижу смысла городить лямбду по любому поводу 13 окт 2016 в 15:01
  • Ну, для типобезопасности я бы не пожалел лямбды. Но это уже вопрос личных предпочтений.
    – VladD
    13 окт 2016 в 15:11
6

Есть более подробный ответ здесь и здесь

  1. Самый простой вариант создать boolean переменную, которая отслеживает запрос на завершение потока. Данный вариант не позволяет прервать Thread.Sleep.

    boolean volatile isRunning = true;
    
    void run(object p)
    {
       while(true)
       {
          if (!isRunning) break; // exit if not running
    
          doAnything(p);
    
          Thread.Sleep(60000);
       }
    }
    
  2. Другой вариант использовать CancellationTokenSource. Подходит начиная с .net 4

2
  • 1
    bool-переменная не позволит оборвать Thread.Sleep.
    – VladD
    13 окт 2016 в 8:33
  • 1
    Да, верно, поправил, хотел описать все варианты возможные, начиная с самых примитивных, но увидел что уже подробно ответ опубликовали пока я писал первый. 13 окт 2016 в 9:40

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.