Как исправить ошибку 'сбой при специализации функции-шаблона' (многопоточность)?

Question

[CodeInside]

Сам проект большой, поэтому выложу фрагменты, которые связаны с потоками.

// В объявлении первого класса
private:
std::thread	firstClassThread;
int run();

// Конструктор данного класса
FirstClass::FirstClass() : /* список инициализаторов */ firstClassThread(run()) { }

// Использование потока
switch (received_data) {
	case FIRST_CONST:
		// ...
		firstClassThread.detach();
		break;

	case SECOND_CONST:
		if (/* logical condition */) {
			// ...
			SuspendThread(firstClassThread.native_handle());
		}
		else if (/* logical condition */) {
			// ...
			ResumeThread(firstClassThread.native_handle());
		}
		break;
}

// Второй класс, объекты которого агрегирует в себе FirstClass
// в объявлении
private:
int someFunc(const int& data);

// В одном из публичных методов этого второго класса
std::thread someFuncThread(someFunc(data), data);
	someFuncThread.detach();
	Sleep(duration);

В итоге я получаю вот такие две ошибки:

1. "std::invoke": не найдена соответствующая перегруженная функция
   
2. Сбой при специализации функции-шаблона "unknown-type std::invoke(_Callable &&,_Types &&...)"
   

Первый раз работаю с многопоточностью. Можете помочь исправить данные ошибки?

Answer 1

[Антон Жилин]

Всё становится проще с лямбдами:

// Было
std::thread someFuncThread(someFunc(data), data);
// Стало
std::thread someFuncThread([this, data] { return this->someFunc(data); });

Аналогично будет в другом месте. Помните:

1. this тоже надо захватывать, и этого не избежать вызовом метода без this, то есть как someFunc(data)
   
2. Это ваши проблемы следить за тем, что на момент вызова объект *this "жив"
   
3. data здесь захватывается по значению. Если объём данных большой, и вы можете гарантировать их время жизни, то захватите по ссылке: [this, &data]
   

Upd Как отложить запуск:

std::thread someFuncThread;
//...
someFuncThread = std::thread( создаём_как_показано_выше );

Comments

[CodeInside]

А что сделать, чтобы поток не запускался сразу же после конструктора? (чтобы запускался только методом detach)

[Евгений Шатунов]

Антон Жилин :

this захватывается по ссылке.

Поправка... en.cppreference.com/w/cpp/language/lambda

[this] captures the this pointer by value

Замыкания для всех работают одинаково. :)

[Антон Жилин]

Евгений Шатунов: Указатель this-то захватится по значению, но если речь идёт о самом текущем объекте *this, то он захватится по ссылке (копии не будет). В C++17 появился "настоящий" захват *this по значению: [*this]

[Евгений Шатунов]

Антон Жилин , источники всегда приветствуются. :)

en.cppreference.com/w/cpp/language/lambda

The capture-list is a comma-separated list of zero or more captures, optionally beginning with the capture-default. The only capture defaults are & (implicitly catch the odr-used automatic variables and *this by reference) and = (implicitly catch the odr-used automatic variables by copy and implicitly catch *this by reference if it is odr-used).

Т.е. только в случае автозахвата. Там же, 8-м номером, написано все про 17й стандарт и захват по значению. Это все понятно.

А разве можно сделать замыкание на *this в 11м/14м стандарте? О_о
cpp.sh/2cxhl

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

[CodeInside]

Евгений Шатунов: а как решить ошибку при вызове " SuspendThread(firstClassThread.native_handle());": this было nullptr?

[Евгений Шатунов]

CodeInside , как я понимаю, функция SuspendThread взята из WinAPI?
Если так, то `native_handle()` у `std::thread` будет хранить HANDLE потока, приведенный к void*.
Источник: https://msdn.microsoft.com/en-us/library/hh920601....

Следовательно, nullptr там может лежать в двух случаях, которые по своей сути одинаковы:
1- объект потока не был инициализирован;
2- объект потока был отвязан от потока - thread.detach().

В любом из этих случаев объект потока не связан с реальным потоком.
Значит выход - пожалуй, detach надо делать в другое время. А может его и вовсе не стоит делать?

[Евгений Шатунов]

CodeInside , да и в целом... страшные это все вещи. Для чего тебе захотелось усыплять потоки?
Ты ведь понимаешь что поток может быть усыплен посреди выполнения некоторой операции с данными или объектом?
Это же страшная штука, от которой волосы дыбом встают. :)

[CodeInside]

Евгений Шатунов: спасибо, решил проблему)

[Антон Жилин]

Евгений Шатунов: Каюсь. Я всегда говорил о [this], как о захвате по ссылке, особенно в свете того, что [&this] нет. Но со стандартом не поспоришь, исправил.

Answer 2

[Евгений Шатунов]

en.cppreference.com/w/cpp/thread/thread/thread

int run(); // Имеет тип `int (FirstClass::*)()`. А конструктору `std::thread` нужен или функтор, или глобальная функция.

Перепиши `run()` на статическую и передавай инстанцию объекта `FirstClass` параметром при запуске.
иное решение - использовать лямбду с замыканием на this.

FirstClass::FirstClass() : /* список инициализаторов */ firstClassThread([this](){ run(); }) { }

Имей в виду что поток запустится сразу же после завершения конструктора `std::thread`.

en.cppreference.com/w/cpp/thread/thread

Threads begin execution immediately upon construction of the associated thread object (pending any OS scheduling delays), starting at the top-level function provided as a constructor argument.

Буквально, поток запускается сразу после его конструирования.

en.cppreference.com/w/cpp/thread/thread/detach

Separates the thread of execution from the thread object, allowing execution to continue independently.

А вот `detach` ничего с запуском потока, или с самим потоком, не делает, она только сбрасывает состояние объекта потока, обрывает связь между объектом потока и самим потоком.

Может тебе стоит как-то иначе запускать поток, в другое время? Если тебе все таки надо запустить поток в другое время, его в это время и надо конструировать.

Comments

[CodeInside]

Да, в другое. А разве не метод detach() запускает? Как тогда отменить запуск после конструктора?

[CodeInside]

+Не могу сделать эти методы статическими, ибо они используют поля объекта, который вызывает данный метод.