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

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

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