Lines Matching refs:threads

42             threads::free_thread_exit_callbacks(id_);  in terminate()
55 : id_(hpx::threads::invalid_thread_id) in thread()
62 rhs.id_ = threads::invalid_thread_id; in thread()
75 rhs.id_ = threads::invalid_thread_id; in operator =()
88 HPX_ASSERT(id_ == threads::invalid_thread_id); in ~thread()
100 threads::thread_id_type id = threads::get_self_id(); in run_thread_exit_callbacks()
101 if (id == threads::invalid_thread_id) { in run_thread_exit_callbacks()
106 threads::run_thread_exit_callbacks(id); in run_thread_exit_callbacks()
109 threads::thread_result_type thread::thread_function_nullary( in thread_function_nullary()
139 return threads::thread_result_type(threads::terminated, in thread_function_nullary()
140 threads::invalid_thread_id); in thread_function_nullary()
150 return hpx::threads::hardware_concurrency(); in hardware_concurrency()
155 threads::thread_init_data data( in start_thread()
163 threads::get_thread_manager().register_thread( in start_thread()
164 data, id_, threads::pending, true, ec); in start_thread()
172 static void resume_thread(threads::thread_id_type const& id) in resume_thread()
174 threads::set_thread_state(id, threads::pending); in resume_thread()
186 native_handle_type this_id = threads::get_self_id(); in join()
197 if (threads::add_thread_exit_callback(id_, in join()
202 this_thread::suspend(threads::suspended, "thread::join"); in join()
211 threads::interrupt_thread(native_handle(), flag); in interrupt()
216 return threads::get_thread_interruption_requested(native_handle()); in interruption_requested()
221 threads::interrupt_thread(id.id_, flag); in interrupt()
226 return threads::get_thread_data(native_handle()); in get_thread_data()
230 return threads::set_thread_data(native_handle(), data); in set_thread_data()
247 thread_task_base(threads::thread_id_type const& id) in thread_task_base()
249 if (threads::add_thread_exit_callback(id, in thread_task_base()
259 return id_ != threads::invalid_thread_id; in valid()
272 threads::interrupt_thread(id_); in cancel()
276 id_ = threads::invalid_thread_id; in cancel()
287 id_ = threads::invalid_thread_id; in thread_exit_function()
291 threads::thread_id_type id_;
297 if (id_ == threads::invalid_thread_id) in get_future()
321 this_thread::suspend(threads::pending, id.native_handle(), in yield_to()
327 this_thread::suspend(threads::pending, "this_thread::yield"); in yield()
332 return thread::id(threads::get_self_id()); in get_id()
336 threads::thread_priority get_priority() in get_priority()
338 return threads::get_thread_priority(threads::get_self_id()); in get_priority()
343 return threads::get_stack_size(threads::get_self_id()); in get_stack_size()
348 threads::interruption_point(threads::get_self_id()); in interruption_point()
353 return threads::get_thread_interruption_enabled(threads::get_self_id()); in interruption_enabled()
358 return threads::get_thread_interruption_requested(threads::get_self_id()); in interruption_requested()
363 threads::interrupt_thread(threads::get_self_id()); in interrupt()
364 threads::interruption_point(threads::get_self_id()); in interrupt()
374 return threads::get_thread_data(threads::get_self_id()); in get_thread_data()
379 return threads::set_thread_data(threads::get_self_id(), data); in set_thread_data()
388 threads::set_thread_interruption_enabled( in disable_interruption()
389 threads::get_self_id(), false); in disable_interruption()
395 threads::thread_self* p = threads::get_self_ptr(); in ~disable_interruption()
397 threads::set_thread_interruption_enabled( in ~disable_interruption()
398 threads::get_self_id(), interruption_was_enabled_); in ~disable_interruption()
409 threads::set_thread_interruption_enabled( in restore_interruption()
410 threads::get_self_id(), true); in restore_interruption()
416 threads::thread_self* p = threads::get_self_ptr(); in ~restore_interruption()
418 threads::set_thread_interruption_enabled( in ~restore_interruption()
419 threads::get_self_id(), interruption_was_enabled_); in ~restore_interruption()