c thread с параметрами
Создание потоков и передача данных во время запуска
При создании процесса в операционной системе она добавляет поток для выполнения кода этого процесса, включая все исходные домены приложений. С этого момента домены приложений могут создаваться и уничтожаться, что не обязательно сопровождается созданием или уничтожением потоков операционной системы. Если выполняемый код является управляемым, то вы можете получить объект Thread для потока, выполняющегося в текущем домене приложения. Для этого получите статическое свойство CurrentThread типа Thread. В этой статье описано создание потока и несколько способов передачи данных в процедуру потока.
Создание потока
Создание нового объекта Thread приводит к созданию нового управляемого потока. Класс Thread имеет конструкторы, которые принимают делегат ThreadStart или ParameterizedThreadStart. Этот делегат инкапсулирует метод, который вызывается новым потоком при вызове метода Start. Повторный вызов Start приводит к созданию исключения ThreadStateException.
Метод Start завершается немедленно, часто даже до запуска нового потока. Вы можете использовать свойства ThreadState и IsAlive, чтобы определить состояние потока в настоящий момент, но эти свойства ни в коем случае нельзя использовать для синхронизации действий потоков.
После запуска потока не нужно сохранять ссылку на объект Thread. Поток продолжит выполняться, пока не завершится запущенная в нем процедура.
В следующем примере кода создается два новых потока для вызова метода экземпляра и статического метода из другого объекта.
Передача данных в потоки
Делегат ParameterizedThreadStart предоставляет простой способ передать в поток объект с данными при вызове Thread.Start(Object). См. пример кода в ParameterizedThreadStart.
Делегат ParameterizedThreadStart не является типобезопасным способом передачи данных, так как метод Thread.Start(Object) принимает любой объект. Вместо этого можно инкапсулировать процедуру потока и данные во вспомогательный класс и выполнять процедуру потока при помощи делегата ThreadStart. В следующем примере показана эта техника.
Ни один из делегатов ThreadStart или ParameterizedThreadStart не имеет возвращаемого значения, так как им некуда возвращать данные после асинхронного вызова. Чтобы получить результаты из метода потока, вы можете использовать метод обратного вызова, как показано в следующем разделе.
Извлечение данных из потоков с помощью методов обратного вызова
Приведенный ниже пример демонстрирует метод обратного вызова, который получает данные из потока. Конструктор класса, содержащего данные и метод потока, также принимает делегат, который представляет метод обратного вызова. Метод потока перед завершением своей работы вызывает этот делегат обратного вызова.
Потоки, блокировки и условные переменные в C++11 [Часть 1]
В первой части этой статьи основное внимание будет уделено потокам и блокировкам в С++11, условные переменные во всей своей красе будут подробно рассмотрены во второй части…
Потоки
В C++11, работа с потокам осуществляется по средствам класса std::thread (доступного из заголовочного файла
Также следует отметить, что если функция потока кидает исключение, то оно не будет поймано try-catch блоком. Т.е. следующий код не будет работать (точнее работать то будет, но не так как было задумано: без перехвата исключений):
Для передачи исключений между потоками, необходимо ловить их в функции потока и хранить их где-то, чтобы, в дальнейшем, получить к ним доступ.
Блокировки
Программа должна выдавать примерно следующее:
Теперь, результат работы программы будет следующего вида:
Можно поспорить насчет того, что метод dump() должен быть константным, ибо не изменяет состояние контейнера. Попробуйте сделать его таковым и получите ошибку при компиляции:
Предположим, что эта функция вызвана из двух разных потоков, из первого потока: элемент удаляется из 1 контейнера и добавляется во 2, из второго потока, наоборот, элемент удаляется из 2 контейнера и добавляется в 1. Это может вызвать deadlock (если контекст потока переключается от одного потока к другому, сразу после первой блокировки).
Новый поток в C++20: std::jthread
Один из участников моего семинара в рамках CppCon 2018 спросил меня: «Может ли std::thread быть прерван (interrupted)?». Мой ответ тогда был — нет, но это уже не совсем так. С C++20 мы можем получить std::jthread (в итоге все таки получили — прим. переводчика).
Позвольте мне развить тему, поднятую на CppCon 2018. Во время перерыва в моем семинаре, посвященному параллелизму, я побеседовал с Николаем (Йосуттисом). Он спросил меня, что я думаю о новом предложении P0660: Cooperatively Interruptible Joining Thread. На тот момент я ничего не знал об этом предложении. Следует отметить, что Николай является одним из авторов этого предложения (наряду с Хербом Саттером и Энтони Уильямсом). Сегодняшняя статья посвящена будущему параллелизма в C++. Ниже я привел общую картину параллелизма в текущем и грядущем C++.
Из названия документа Cooperatively Interruptible Joining Thread (совместно прерываемый присоединяемый поток) вы можете догадаться, что новый поток имеет две новые возможности: прерываемость (interruptible) и автоматическое присоединение (automatically joining, здесь и далее «присоединение» — блокировка вызывающего потока до завершения выполнения, результат вызова метода join() — прим. переводчика). Позвольте мне сначала рассказать вам об автоматическом присоединении.
Автоматическое присоединение
При выполнении программа терминируется.
В следующем примере я заменяю хедер
Прерывание std::jthread
Чтобы было от чего отталкиваться, позвольте мне продемонстрировать вам простой пример.
Вот более подробная информация о токенах прерывания (interrupt tokens), присоединяющихся потоках и условных переменных.
Токены прерывания
Если токен прерывания должен быть временно отключен, вы можете заменить его дефолтным токеном. Дефолтный токен не валиден. Следующий фрагмент кода демонстрирует, как включать и отключать возможность потока принимать сигналы.
std::interrupt_token interruptDisabled не валиден. Это означает, что поток не может принять прерывание между строками (1) и (2), но после строки (2) уже может.
Присоединение потоков
Новые перегрузки Wait для условных переменных
Что дальше?
Как я и обещал в своей последней статье, следующая статья будет посвящена оставшимся правилам определения концептов (concepts).
Смотреть запись демо-занятия по теме «Области видимости и невидимости»: участники вместе с экспертом попробовали реализовать класс общего назначения и запустить несколько unit-тестов с использованием googletest.
Parameterized Thread Start Делегат
Определение
Представляет метод, который выполняется в отношении Thread. Represents the method that executes on a Thread.
Параметры
Объект, содержащий данные потоковой процедуры. An object that contains data for the thread procedure.
Примеры
В следующем примере кода делегат используется ParameterizedThreadStart для выполнения статического метода и метода экземпляра. The following code example uses a ParameterizedThreadStart delegate to execute a static method and an instance method. Первый ParameterizedThreadStart делегат представлен статическим DoWork методом, а второй представляется DoMoreWork методом экземпляра. The first ParameterizedThreadStart delegate is represented by the static DoWork method and the second is represented by the instance DoMoreWork method. Оба метода соответствуют ParameterizedThreadStart сигнатуре делегата, то есть имеют один параметр типа Object и не возвращают значение. Both methods match the ParameterizedThreadStart delegate signature; that is, they have a single parameter of type Object and don’t return a value.
Компиляторы Visual Basic и C# выводят ParameterizedThreadStart делегат из сигнатур DoWork DoMoreWork методов и и вызывают правильный конструктор. The Visual Basic and C# compilers infer the ParameterizedThreadStart delegate from the signatures of the DoWork and DoMoreWork methods, and call the correct constructor. Таким образом, в коде отсутствует явный вызов конструктора. Thus, there is no explicit constructor call in the code.
Комментарии
При создании управляемого потока метод, выполняемый в потоке, представляется следующим образом: When a managed thread is created, the method that executes on the thread is represented by:
ThreadStartДелегат, который передается в Thread.Thread(ThreadStart) конструктор. A ThreadStart delegate that is passed to the Thread.Thread(ThreadStart) constructor. Любой метод, не имеющий параметров и возвращающий void в C# или являющийся Sub процедурой в Visual Basic может представлять делегат. Any method that has no parameters and that returns void in C# or is a Sub procedure in Visual Basic can represent the delegate.
ParameterizedThreadStartДелегат, который передается в Thread.Thread(ParameterizedThreadStart) конструктор. A ParameterizedThreadStart delegate that is passed to the Thread.Thread(ParameterizedThreadStart) constructor. Любой метод с одним параметром типа Object и, который возвращает void в C# или является подпроцедурой в Visual Basic может представлять делегат. Any method that has a single parameter of type Object and that returns void in C# or is a Sub procedure in Visual Basic can represent the delegate.
Поток не начинает выполняться до Thread.Start вызова метода. The thread does not begin executing until the Thread.Start method is called. ThreadStartДелегат или ParameterizedThreadStart вызывается в потоке, а выполнение начинается с первой строки метода, представленного делегатом. The ThreadStart or ParameterizedThreadStart delegate is invoked on the thread, and execution begins at the first line of the method represented by the delegate. В случае ParameterizedThreadStart делегата объект, передаваемый в Start(Object) метод, передается делегату. In the case of the ParameterizedThreadStart delegate, the object that is passed to the Start(Object) method is passed to the delegate.
При создании ParameterizedThreadStart делегата для метода экземпляра в C++ первым параметром конструктора является переменная экземпляра. When you create a ParameterizedThreadStart delegate for an instance method in C++, the first parameter of the constructor is the instance variable. Для статического метода первый параметр конструктора равен нулю. For a static method, the first parameter of the constructor is zero. Для статического метода конструктор делегата требует только одного параметра: адрес метода обратного вызова, дополненного именем класса. For a static method, the delegate constructor requires only one parameter: the address of the callback method, qualified by the class name.
ParameterizedThreadStartДелегат поддерживает только один параметр. The ParameterizedThreadStart delegate supports only a single parameter. В можно передать несколько элементов данных, ParameterizedThreadStart сделав этот параметр одним из следующих: You can pass multiple data items to the ParameterizedThreadStart by making that parameter one of the following:
Тип коллекции, если все элементы данных имеют один и тот же тип. A collection type, if all of the data items are of the same type.
Методы расширения
Получает объект, представляющий метод, представленный указанным делегатом. Gets an object that represents the method represented by the specified delegate.
к примеру Object.Method(a,b,c)
3 ответа 3
Если нужно запустить поток, передав несколько аргументов, то проще всего это сделать, создав новый класс.
Например использовать параметризированный конструктор потока Thread. Пример с МСДН. Чтобы передать несколько значений оберните их в класс и передавайте в метод.
На текущий момент (2018 год), для запуска нового потока проще всего использовать лямбда-функции:
При этом вам не нужно создавать класс-обёртку для ваших данных: данные хранятся в замыкании лямбда-функции.
Ещё более хорошим вариантом является использование TPL и async/await. При этом вы сможете легко возвращать данные из потока:
Всё ещё ищете ответ? Посмотрите другие вопросы с метками c# потоки-данных многопоточность или задайте свой вопрос.
Связанные
Похожие
Подписаться на ленту
Для подписки на ленту скопируйте и вставьте эту ссылку в вашу программу для чтения RSS.
дизайн сайта / логотип © 2021 Stack Exchange Inc; материалы пользователей предоставляются на условиях лицензии cc by-sa. rev 2021.9.16.40224
Нажимая «Принять все файлы cookie» вы соглашаетесь, что Stack Exchange может хранить файлы cookie на вашем устройстве и раскрывать информацию в соответствии с нашей Политикой в отношении файлов cookie.