Вопрос по Потокам в C#

Question

Запускаю несколько потоков, которые будут выполнятся по очереди.

Реализую это блокировками.

System.Threading.Monitor.Enter(this);

тут код.

System.Threading.Monitor.Exit(this);

Далее к примеру при нажатии кнопки потоки должны останавливаться, я их убиваю и удаляю.

Далее я хочу снова создать и запустить потоки, НО когда я останавливал и удалял потоки ( блокировка System.Threading.Monitor.Enter(this); видимо не отыграла).

Т.е я создаю новые потоки и запускаю их, но они не будут работать, т.к стоит блокировка.. 

Как можно решить эту проблему? Т.е не из самого потока грамотно завершить все потоки и самое главное снять снять блокировку.

Заранее спасибо!

Answer 1

А как Вы убиваете потоки? Можно вызвать Abort или Interrupt для потока, а в функции потока перехватывать исключение ThreadAbortException или ThreadInterruptedException соответственно и выполнять в обработчике все действия по снятию блокировок и проч.

Answer 2

Еще вариант: использовать в функции потока конструкцию C# lock. Она как раз и реализована при помощи монитора, только Enter и Exit вызываются автоматически.

lock(this)
{
    // здесь код
}

Answer 3

Вообще удаление/завершение потоков не рекомендуется делать. Уж лучше отмену через CancellationTokenSource.

Answer 4

Весь метод брать в try {} catch{} наверно будет не оправдано с точки зрения оптимизации.

Answer 5

Вариант интересный, но у меня в методе для потоков есть разветвления, и при определённых условиях поток освобождается в разных местах.

Answer 6

Возможно это то, что мне нужно, не могли бы вы написать пример?
Я конечно читаю сейчас про этот класс, но пока не до конца понял как он работает.

Answer 7

Если Вы приведете пример своего кода, то можно попробовать сразу переделать его с помощью отмены.

Answer 8

//Метод для потоков.
void Read(object TestList)
{
do
{

System.Threading.Monitor.Enter(this);

// тут основной алгоритм программы.

 
System.Threading.Monitor.Exit(this);
 
Thread.Sleep(100000);

}
while(true);


}

//создание и запуск потоков.
private void start_click(object sender, EventArgs e)
{
while(..)
{
Thread OutRead = new Thread(Read);
OutRead.Name = Arrays[index].ID.ToString();
OutReadLIST.Add(OutRead);
OutRead.Start(Arrays[index]);
}
}

//здесь необходимо завершить потоки и освободить блокировки.

private void close(object sender, EventArgs e)
{ 
int index = 0;
while (index != OutReadLIST.Count())
{
OutReadLIST[index].Abort();                
index++;
}
OutReadLIST.Clear();

}

Answer 9

Вот так нужно оформить метод для потока:

//Метод для потоков.
void Read(object TestList)
{
  do
  {

    lock(this)
    {
       // тут основной алгоритм программы.
    }

    Thread.Sleep(100000);

  }
  while(true);
}

Больше никаких изменений не потребуется, т.к. блокировка будет гарантировано освобождена в случае исключения.

Answer 10

Небольшой вариант:

    class Program
    {
        private static void Main(string[] args)
        {
            Start();
            Console.ReadKey();
        }

        private static void Start()
        {
            var ids = new[] { 0, 1, 2, 3, 4, 5 };
            // Создаем токен для отмены
            var cancellationTokenSource = new CancellationTokenSource();
            foreach (var id in ids)
            {
                // Запускаем задачи и передаем объект-состояние и токен отмены
                var value = id;
                Task.Factory.StartNew(() => Read(value, cancellationTokenSource.Token), cancellationTokenSource.Token);
            }
            // Отменяем все задачи
            Task.Factory.StartNew(() => Close(cancellationTokenSource), cancellationTokenSource.Token);
            // Или же просто так
            // Close(cancellationTokenSource);
        }

        //здесь необходимо завершить потоки.
        private static void Close(CancellationTokenSource cancellationTokenSource)
        {
            Thread.Sleep(5000);
            // Отмена все потоков, связанных с этим токеном
            cancellationTokenSource.Cancel();
        }

        //Метод для потоков.
        private static void Read(Object id, CancellationToken tokenSource)
        {
            Console.WriteLine("Thread {0}", id);
            while (true)
            {
                // Прверяем, была ли вызвана отмена
                if (tokenSource.IsCancellationRequested)
                {
                    // Завершаем выполнение
                    Console.WriteLine("Cancel thread {0}", id);
                    break;
                }
            }
        }
    }

В данном случае для всех потоков существует один и тот же токен отмены. Соответственно, если происходит отмена - об этом узнают все потоки. Однако для большой гибкости можно для каждой задачи создавать свой токен, что позволит отменять только требуемые потоки (а не все сразу).

Answer 11

Так тоже можно, но только изменить lock(THIS)!!!

    class Program
    {
        static readonly Object sync = new Object();

        private static void Main(string[] args)
        {
            Start();
            Console.ReadKey();
        }

        private static void Start()
        {
            var ids = new[] { 0, 1, 2, 3, 4, 5 };
            var threads = new Collection<Thread>();
            foreach (var id in ids)
            {
                var thread = new Thread(Read) {Name = String.Format("Thread {0}", id)};
                threads.Add(thread);
                thread.Start(id);
            }

            Thread.Sleep(1000);
            threads.ElementAt(0).Abort();
        }

        //Метод для потоков.
        static void Read(object id)
        {
            Console.WriteLine("Thread {0}", id);
            do
            {

                lock (sync)
                {
                    Console.WriteLine("Lock thread {0}", id);
                    // тут основной алгоритм программы.
                    Thread.Sleep(10000);
                }
            }
            while (true);
        }
    }

Answer 12

Безусловно, но только с точки зрения добавления новых критических секций в будущем. В данном случае это не имеет никакого отношения к вопросу уважаемого ivanich274.

Answer 13

Небольшой вариант:

    class Program
    {
        private static void Main(string[] args)
        {
            Start();
            Console.ReadKey();
        }

        private static void Start()
        {
            var ids = new[] { 0, 1, 2, 3, 4, 5 };
            // Создаем токен для отмены
            var cancellationTokenSource = new CancellationTokenSource();
            foreach (var id in ids)
            {
                // Запускаем задачи и передаем объект-состояние и токен отмены
                var value = id;
                Task.Factory.StartNew(() => Read(value, cancellationTokenSource.Token), cancellationTokenSource.Token);
            }
            // Отменяем все задачи
            Task.Factory.StartNew(() => Close(cancellationTokenSource), cancellationTokenSource.Token);
            // Или же просто так
            // Close(cancellationTokenSource);
        }

        //здесь необходимо завершить потоки.
        private static void Close(CancellationTokenSource cancellationTokenSource)
        {
            Thread.Sleep(5000);
            // Отмена все потоков, связанных с этим токеном
            cancellationTokenSource.Cancel();
        }

        //Метод для потоков.
        private static void Read(Object id, CancellationToken tokenSource)
        {
            Console.WriteLine("Thread {0}", id);
            while (true)
            {
                // Прверяем, была ли вызвана отмена
                if (tokenSource.IsCancellationRequested)
                {
                    // Завершаем выполнение
                    Console.WriteLine("Cancel thread {0}", id);
                    break;
                }
            }
        }
    }

В данном случае для всех потоков существует один и тот же токен отмены. Соответственно, если происходит отмена - об этом узнают все потоки. Однако для большой гибкости можно для каждой задачи создавать свой токен, что позволит отменять только требуемые потоки (а не все сразу).

Отлично, но где здесь блокировка потоков?И куда вообще поместить алгоритм?

do
{
   Monitor.Enter

  //код  алгоритма
   Monitror.Exit;

}
while(true);

Можно пожалуйста на примере моего кода?

 Заранее спасибо.

Answer 14

В метод Read и помещаете свой алгоритм.

Answer 15

В метод Read и помещаете свой алгоритм.

Это понятно,  не понятно куда именно. 

Answer 16

do
{
   Monitor.Enter

  //код  алгоритма
   Monitror.Exit;

}
while(true);

Помещаете в метод Read, и там где надо делаете проверку отмены выполнения потока

if (tokenSource.IsCancellationRequested)

Answer 17

do
{
   Monitor.Enter

  //код  алгоритма
   Monitror.Exit;

}
while(true);

Помещаете в метод Read, и там где надо делаете проверку отмены выполнения потока

if (tokenSource.IsCancellationRequested)

В том и дело, что я не знаю в каком именно месте кода я захочу остановить поток, я же не буду через каждую строчку писать условие

if (tokenSource.IsCancellationRequested)

Answer 18

Здравствуйте. Механизм, предложенный уважаемым Kirill Bessonov, это попытка Microsoft реализовать в .NET Framework версии 4 и выше концепцию 'Cancellation points", которая давно существовала в Unix-подобных системах. Смысл ее - явным образом задать точки в коде потока, в которых поток можно безболезненно прервать. Эти точки, как я понимаю, теперь присутствуют во многих функциях библиотеки .NET Framework. Если Вы хотите задействовать этот механизм в своем коде, то самостоятельно должны принять решение о том, где разместить такие точки прерывания. А вообще, мне кажется, что данная дискуссия уже выходит за рамки Вашего вопроса. Вам было предложено ДВА решения. Определитесь, какое из них подходит Вам и закрывайте вопрос.