Última atualização:2026-10-12
Implementação interna de std::thread em C++¶
Revelando a fundo o std::thread¶
Quando escrevemos uma lambda e a passamos para thread, quando são disparados a criação do thread e a chamada da task?
Passamos uma lambda para este thread, e a questão que esta seção busca responder é: quando essa lambda é disparada? No momento da construção? Ou quando é chamada em algum ponto?Vamos entrar juntos na era do código-fonte.
1._M_make_routine¶
Os códigos analisados nesta seção são, respectivamente:
1) arquivo de cabeçalho
https://github.com/gcc-mirror/gcc/blob/releases/gcc-4.9/libstdc%2B%2B-v3/include/std/thread
- arquivo de implementação
https://github.com/gcc-mirror/gcc/blob/releases/gcc-4.9/libstdc%2B%2B-v3/src/c%2B%2B11/thread.cc
- cabeçalho posix
https://github.com/gcc-mirror/gcc/blob/releases/gcc-4.9/libgcc/gthr-posix.h
O código acima chama o seguinte construtor:
template<typename _Callable, typename... _Args>
explicit
thread(_Callable&& __f, _Args&&... __args)
{
_M_start_thread(_M_make_routine(std::__bind_simple(
std::forward<_Callable>(__f),
std::forward<_Args>(__args)...)));
}
__f é a lambda que passamos; aqui o bind vincula a lambda aos parâmetros, e em seguida ela é passada para _M_make_routine, que constrói o _Impl.
template<typename _Callable>
shared_ptr<_Impl<_Callable>>
_M_make_routine(_Callable&& __f)
{
// Create and allocate full data structure, not base.
return std::make_shared<_Impl<_Callable>>(std::forward<_Callable>(__f));
}
_Impl fica armazenado _M_func, o resultado do bind de antes.
template<typename _Callable>
struct _Impl : public _Impl_base
{
_Callable _M_func;
_Impl(_Callable&& __f) : _M_func(std::forward<_Callable>(__f))
{ }
void
_M_run() { _M_func(); }
};
shared_ptr<_Impl<_Callable>> criado por _M_make_routine é passado para _M_start_thread.
2._M_start_thread¶
_M_start_thread chama __gthread_create, e aqui é passado execute_native_thread_routine.
void
thread::_M_start_thread(__shared_base_type __b)
{
if (!__gthread_active_p())
#if __EXCEPTIONS
throw system_error(make_error_code(errc::operation_not_permitted),
"Enable multithreading to use std::thread");
#else
__throw_system_error(int(errc::operation_not_permitted));
#endif
__b->_M_this_ptr = __b;
int __e = __gthread_create(&_M_id._M_thread,
&execute_native_thread_routine, __b.get());
if (__e)
{
__b->_M_this_ptr.reset();
__throw_system_error(__e);
}
}
execute_native_thread_routine
O código abaixo traz algumas informações:
Primeiro: por que usar extern "C"
Segundo: ele chama _M_run()
extern "C"
{
static void*
execute_native_thread_routine(void* __p)
{
thread::_Impl_base* __t = static_cast<thread::_Impl_base*>(__p);
thread::__shared_base_type __local;
__local.swap(__t->_M_this_ptr);
__try
{
__t->_M_run();
}
__catch(const __cxxabiv1::__forced_unwind&)
{
__throw_exception_again;
}
__catch(...)
{
std::terminate();
}
return 0;
}
} // extern "C"
__gthread_create
Ele chama pthread_create
static inline int
__gthread_create (__gthread_t *__threadid, void *(*__func) (void*),
void *__args)
{
return __gthrw_(pthread_create) (__threadid, NULL, __func, __args);
}
_M_run() interno é executado — e isso corresponde à chamada da nossa função lambda.
Com esta seção, damos um passo adiante no entendimento das chamadas de thread. Você aprendeu? Fique à vontade para compartilhar.
Tópicos relacionados¶
- Guia de C++ Concurrency in Action | C++那些事
- Depuração de Deadlocks em C++ | C++那些事
- Vetorização SIMD em C++ | C++那些事
- STL Paralela do C++17 | C++那些事
- False Sharing e Linhas de Cache em C++ | C++那些事
- Depuração All-Stop multi-thread com GDB | C++那些事
- Detecção de Erros de Concorrência com Helgrind | C++那些事
- Princípio do event loop do libev | C++那些事
- C++ std::thread e jthread | C++那些事
- Introdução a multi-thread em C++ | C++那些事