C # — многопоточность

using System;
using System.Threading;

namespace MultithreadingApplication {
   class MainThreadProgram {
      static void Main(string[] args) {
         Thread th = Thread.CurrentThread;
         th.Name = "MainThread";
         
         Console.WriteLine("This is {0}", th.Name);
         Console.ReadKey();
      }
   }
}

Когда приведенный выше код компилируется и выполняется, он дает следующий результат —

This is MainThread

Свойства и методы класса Thread

В следующей таблице приведены некоторые наиболее часто используемые свойства класса Thread.

CurrentContext

Получает текущий контекст, в котором выполняется поток.

CurrentCulture

Получает или задает культуру для текущего потока.

CurrentPrinciple

Получает или задает текущего участника потока (для безопасности на основе ролей).

CurrentThread

Получает текущий запущенный поток.

CurrentUICulture

Получает или задает текущую культуру, используемую Resource Manager для поиска ресурсов, специфичных для данной культуры, во время выполнения.

ExecutionContext

Получает объект ExecutionContext, который содержит информацию о различных контекстах текущего потока.

Является живым

Получает значение, указывающее состояние выполнения текущего потока.

IsBackground

Получает или задает значение, указывающее, является ли поток фоновым потоком.

IsThreadPoolThread

Получает значение, указывающее, принадлежит ли поток к пулу управляемых потоков.

ManagedThreadId

Получает уникальный идентификатор для текущего управляемого потока.

название

Получает или задает имя потока.

приоритет

Получает или задает значение, указывающее приоритет планирования потока.

ThreadState

Получает значение, содержащее состояния текущего потока.

В следующей таблице приведены некоторые из наиболее часто используемых методов класса Thread.

публичный void Abort ()

Вызывает исключение ThreadAbortException в потоке, в котором он вызывается, чтобы начать процесс завершения потока. Вызов этого метода обычно завершает поток.

public static LocalDataStoreSlot AllocateDataSlot ()

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

public static LocalDataStoreSlot AllocateNamedDataSlot (имя строки)

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

public static void BeginCriticalRegion ()

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

public static void BeginThreadAffinity ()

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

public static void EndCriticalRegion ()

Уведомляет хост о том, что выполнение собирается ввести область кода, в которой эффекты прерывания или необработанного исключения потока ограничены текущей задачей.

public static void EndThreadAffinity ()

Уведомляет хост, что управляемый код завершил выполнение инструкций, которые зависят от идентификатора текущего физического потока операционной системы.

публичная статическая пустота FreeNamedDataSlot (имя строки)

Устраняет связь между именем и слотом для всех потоков в процессе. Для повышения производительности используйте поля, помеченные атрибутом ThreadStaticAttribute.

открытый статический объект GetData (слот LocalDataStoreSlot)

Извлекает значение из указанного слота в текущем потоке в текущем домене текущего потока. Для повышения производительности используйте поля, помеченные атрибутом ThreadStaticAttribute.

публичный статический AppDomain GetDomain ()

Возвращает текущий домен, в котором работает текущий поток.

публичный статический AppDomain GetDomainID ()

Возвращает уникальный идентификатор домена приложения

public static LocalDataStoreSlot GetNamedDataSlot (имя строки)

Ищет именованный слот данных. Для повышения производительности используйте поля, помеченные атрибутом ThreadStaticAttribute.

public void Interrupt ()

Прерывает поток, находящийся в состоянии потока WaitSleepJoin.

public void Join ()

Блокирует вызывающий поток до тех пор, пока поток не завершится, продолжая при этом выполнять стандартную прокачку COM и SendMessage. Этот метод имеет разные перегруженные формы.

public static void MemoryBarrier ()

Синхронизирует доступ к памяти следующим образом: Процессор, выполняющий текущий поток, не может переупорядочить инструкции таким образом, чтобы доступ к памяти до выполнения вызова MemoryBarrier выполнялся после обращений к памяти, которые следуют после вызова MemoryBarrier.

общедоступная статическая пустота ResetAbort ()

Отменяет прерывание, запрошенное для текущего потока.

public static void SetData (слот LocalDataStoreSlot, данные объекта)

Устанавливает данные в указанном слоте текущего запущенного потока для текущего домена этого потока. Для повышения производительности используйте поля, помеченные атрибутом ThreadStaticAttribute.

public void Start ()

Начинает поток.

public static void Sleep (int millisecondsTimeout)

Заставляет нить приостановиться на некоторое время.

общедоступная статическая пустота SpinWait (int iterations)

Заставляет поток ждать количество раз, определенное параметром iterations

открытый статический байт VolatileRead (адрес байта)

public static double VolatileRead (ссылка на двойной адрес)

public static int VolatileRead (ref int address)

публичный статический объект VolatileRead (ссылка на адрес объекта)

Читает значение поля. Значение является последним, записанным любым процессором в компьютере, независимо от количества процессоров или состояния кэша процессора. Этот метод имеет разные перегруженные формы. Только некоторые из них приведены выше.

public static void VolatileWrite (адрес байта, значение байта)

public static void VolatileWrite (ссылка двойной адрес, двойное значение)

public static void VolatileWrite (ref int address, int value)

public static void VolatileWrite (ref Адрес объекта, Значение объекта)

Немедленно записывает значение в поле, чтобы оно было доступно всем процессорам компьютера. Этот метод имеет разные перегруженные формы. Только некоторые из них приведены выше.

public static bool Yield ()

Заставляет вызывающий поток передать выполнение другому потоку, который готов к запуску на текущем процессоре. Операционная система выбирает поток для уступки.

Создание тем

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

Следующая программа демонстрирует концепцию —

Live Demo

using System;
using System.Threading;

namespace MultithreadingApplication {
   class ThreadCreationProgram {
      public static void CallToChildThread() {
         Console.WriteLine("Child thread starts");
      }
      static void Main(string[] args) {
         ThreadStart childref = new ThreadStart(CallToChildThread);
         Console.WriteLine("In Main: Creating the Child thread");
         Thread childThread = new Thread(childref);
         childThread.Start();
         Console.ReadKey();
      }
   }
}

In Main: Creating the Child thread
Child thread starts

using System;
using System.Threading;

namespace MultithreadingApplication {
   class ThreadCreationProgram {
      public static void CallToChildThread() {
         Console.WriteLine("Child thread starts");
         
         // the thread is paused for 5000 milliseconds
         int sleepfor = 5000; 
         
         Console.WriteLine("Child Thread Paused for {0} seconds", sleepfor / 1000);
         Thread.Sleep(sleepfor);
         Console.WriteLine("Child thread resumes");
      }
      
      static void Main(string[] args) {
         ThreadStart childref = new ThreadStart(CallToChildThread);
         Console.WriteLine("In Main: Creating the Child thread");
         
         Thread childThread = new Thread(childref);
         childThread.Start();
         Console.ReadKey();
      }
   }
}

In Main: Creating the Child thread
Child thread starts
Child Thread Paused for 5 seconds
Child thread resumes

using System;
using System.Threading;

namespace MultithreadingApplication {
   class ThreadCreationProgram {
      public static void CallToChildThread() {
         try {
            Console.WriteLine("Child thread starts");
            
            // do some work, like counting to 10
            for (int counter = 0; counter <= 10; counter++) {
               Thread.Sleep(500);
               Console.WriteLine(counter);
            }
            
            Console.WriteLine("Child Thread Completed");
         } catch (ThreadAbortException e) {
            Console.WriteLine("Thread Abort Exception");
         } finally {
            Console.WriteLine("Couldn't catch the Thread Exception");
         }
      }
      static void Main(string[] args) {
         ThreadStart childref = new ThreadStart(CallToChildThread);
         Console.WriteLine("In Main: Creating the Child thread");
         
         Thread childThread = new Thread(childref);
         childThread.Start();
         
         //stop the main thread for some time
         Thread.Sleep(2000);
         
         //now abort the child
         Console.WriteLine("In Main: Aborting the Child thread");
         
         childThread.Abort();
         Console.ReadKey();
      }
   }
}