Задержка начала потока в C++ 11

Question

Я попадаю в потоки C++ 11 и столкнулся с проблемой.

Я хочу объявить переменную потока как глобальную и начать ее позже.

Однако все примеры, которые я видел, кажется, запустить поток немедленно, например

thread t(doSomething); 

То, что я хочу

thread t; 

и запустить поток позже.

То, что я пытался это

if(!isThreadRunning) 
{ 
    thread t(readTable); 
} 

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

Спасибо за любую помощь.

Answer 1

Я бы дал нить условие переменной и логическое имя, которое называется startRunning (изначально установлено значение false). Эффективно вы должны начать поток сразу после создания, но первое, что он сделал бы, это приостановить себя (используя условие_вариабельный), а затем начать обработку своей фактической задачи, когда сигнализация condition_variable будет выдана извне (а флаг startRunning установлен в true).

РЕДАКТИРОВАТЬ: псевдокод:

// in your worker thread 
{ 
    lock_guard l(theMutex); 

    while (! startRunning) 
    { 
     cond_var.wait(l); 
    } 
} 

// now start processing task 


// in your main thread (after creating the worker thread) 
{ 
    lock_guard l(theMutex); 
    startRunning = true; 
    cond_var.signal_one(); 
} 

РЕДАКТИРОВАТЬ # 2: В приведенной выше коде, переменные theMutex, startRunning и cond_var должен быть доступным с обеими нитями. Достигаете ли вы этого, делая их глобальными или инкапсулируя их в экземпляр struct/class, зависит от вас.

Answer 2

Вы можете использовать singleton pattern. Или я бы сказал: antipattern.

Внутри синглтона у вас будет std::thread объект инкапсулирован. При первом доступе к singleton ваш поток будет создан и запущен.

Answer 3

std::thread По умолчанию конструктор создает экземпляр std::thread без запуска или представления фактической темы.

std::thread t; 

Оператор присваивания перемещает состояние объекта потока, и устанавливает назначенный-от объекта потока его по умолчанию инициализируется состояние:

t = std::thread(/* new thread code goes here */); 

Это первый строит временный объект потока, представляющий новый thread, переносит новое представление потока в существующий объект потока, который имеет состояние по умолчанию, и устанавливает состояние состояния временного потока в состояние по умолчанию, которое не представляет ни одного работающего потока. Затем временный объект потока уничтожается, ничего не делая.

Вот пример:

#include <iostream> 
#include <thread> 

void thread_func(const int i) { 
    std::cout << "hello from thread: " << i << std::endl; 
} 

int main() { 
    std::thread t; 
    std::cout << "t exists" << std::endl; 

    t = std::thread{ thread_func, 7 }; 
    t.join(); 

    std::cout << "done!" << std::endl; 
} 

Answer 4

Там нет «стандарт» в создании потока «приостановлено», который я предполагаю, что вы хотите делать с библиотекой потоков в C++. Поскольку он не поддерживается на каждой платформе, имеющей потоки, ее нет в C++ API.

1. Возможно, вы захотите создать класс со всеми требуемыми данными, но не на самом деле запустить свою функцию потока. Это не то же самое, что создавать поток, но может быть тем, что вы хотите. Если это так, создайте это, а затем свяжите объект и его функцию operator() или start() или что-то в этом потоке.

2. Возможно, вам понадобится идентификатор потока для вашей темы. Это означает, что вам действительно нужно запустить функцию потока. Однако он может начинаться с ожидания переменной состояния. Затем вы передаете или передаете эту переменную условия позже, когда хотите продолжить ее выполнение. Конечно, вы можете проверить функцию после того, как она возобновится, если вы, возможно, решили закрыть ее и не запустить ее в конце концов (в этом случае она просто вернется сразу).

3. Возможно, вам нужен объект std::thread без функции. Вы можете сделать это и прикрепить его к функции позже до run, которые работают в новом потоке.