| /third_party/boost/libs/thread/test/ |
| D | test_3837.cpp | 21 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in dummy_class_tracks_deletions()
26 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in ~dummy_class_tracks_deletions()
42 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in other_thread()
44 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in other_thread()
46 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in other_thread()
48 this_thread::sleep(posix_time::seconds(5)); in other_thread()
50 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in other_thread()
57 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in main()
59 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in main()
61 std::cout << __FILE__ << ":" << __LINE__ << boost::this_thread::get_id() << std::endl; in main()
[all …]
|
| D | test_thread_exit.cpp | 23 exit_func_thread_id=boost::this_thread::get_id(); in exit_func()
28 boost::this_thread::at_thread_exit(exit_func); in tf1()
29 BOOST_CHECK(exit_func_thread_id!=boost::this_thread::get_id()); in tf1()
45 exit_func_thread_id=boost::this_thread::get_id(); in operator ()()
51 boost::this_thread::at_thread_exit(fo()); in tf2()
52 BOOST_CHECK(exit_func_thread_id!=boost::this_thread::get_id()); in tf2()
|
| D | test_3628.cpp | 33 cout << "Added " << boost::this_thread::get_id() << " " << &con1 << endl; in ThreadFuncWaiter()
36 cout << "Woke Up " << boost::this_thread::get_id() << " " << &con1 << endl; in ThreadFuncWaiter()
40 cout << "*****Timed Out " << boost::this_thread::get_id() << " " << &con1 << endl; in ThreadFuncWaiter()
45 cout << "Removed " << boost::this_thread::get_id() << " " << &con1 << endl; in ThreadFuncWaiter()
50 boost::this_thread::sleep_for(boost::chrono::milliseconds(200)); in ThreadFuncWaiter()
75 boost::this_thread::sleep_for(boost::chrono::milliseconds(50)); in ThreadFuncNotifier()
|
| D | test_4648.cpp | 26 std::cout<<"Entering "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl; in firstFunction()
29 std::cout<<"Returned From Call "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl; in firstFunction()
30 std::cout<<"Returning from "<<boost::this_thread::get_id()<<" "<<"firstFunction"<<std::endl; in firstFunction()
34 …std::cout<<"Before Exclusive Locking "<<boost::this_thread::get_id()<<" "<<"secondFunction"<<std::… in secondFunction()
36 …std::cout<<"After Exclusive Locking "<<boost::this_thread::get_id()<<" "<<"secondFunction"<<std::e… in secondFunction()
|
| D | test_2309.cpp | 24 boost::this_thread::sleep(boost::posix_time::seconds(100)); in perform()
29 cerr << "Thread " << boost::this_thread::get_id() << " got interrupted" << endl; in perform()
35 … cerr << "Thread " << boost::this_thread::get_id() << " caught std::exception" << e.what() << endl; in perform()
40 cerr << "Thread " << boost::this_thread::get_id() << " caught something else" << endl; in perform()
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | thread_info_base.hpp | 78 static void* allocate(thread_info_base* this_thread, std::size_t size) in allocate() argument
80 return allocate(default_tag(), this_thread, size); in allocate()
83 static void deallocate(thread_info_base* this_thread, in deallocate() argument
86 deallocate(default_tag(), this_thread, pointer, size); in deallocate()
90 static void* allocate(Purpose, thread_info_base* this_thread, in allocate() argument
95 if (this_thread && this_thread->reusable_memory_[Purpose::mem_index]) in allocate()
97 void* const pointer = this_thread->reusable_memory_[Purpose::mem_index]; in allocate()
98 this_thread->reusable_memory_[Purpose::mem_index] = 0; in allocate()
117 static void deallocate(Purpose, thread_info_base* this_thread, in deallocate() argument
122 if (this_thread && this_thread->reusable_memory_[Purpose::mem_index] == 0) in deallocate()
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | thread_info_base.hpp | 78 static void* allocate(thread_info_base* this_thread, std::size_t size) in allocate() argument
80 return allocate(default_tag(), this_thread, size); in allocate()
83 static void deallocate(thread_info_base* this_thread, in deallocate() argument
86 deallocate(default_tag(), this_thread, pointer, size); in deallocate()
90 static void* allocate(Purpose, thread_info_base* this_thread, in allocate() argument
95 if (this_thread && this_thread->reusable_memory_[Purpose::mem_index]) in allocate()
97 void* const pointer = this_thread->reusable_memory_[Purpose::mem_index]; in allocate()
98 this_thread->reusable_memory_[Purpose::mem_index] = 0; in allocate()
117 static void deallocate(Purpose, thread_info_base* this_thread, in deallocate() argument
122 if (this_thread && this_thread->reusable_memory_[Purpose::mem_index] == 0) in deallocate()
[all …]
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | scheduler.ipp | 197 thread_info this_thread;
198 this_thread.private_outstanding_work = 0;
199 thread_call_stack::context ctx(this, this_thread);
204 for (; do_run_one(lock, this_thread, ec); lock.lock())
219 thread_info this_thread;
220 this_thread.private_outstanding_work = 0;
221 thread_call_stack::context ctx(this, this_thread);
225 return do_run_one(lock, this_thread, ec);
237 thread_info this_thread;
238 this_thread.private_outstanding_work = 0;
[all …]
|
| D | win_iocp_io_context.ipp | 200 win_iocp_thread_info this_thread;
201 thread_call_stack::context ctx(this, this_thread);
204 while (do_one(INFINITE, this_thread, ec))
219 win_iocp_thread_info this_thread;
220 thread_call_stack::context ctx(this, this_thread);
222 return do_one(INFINITE, this_thread, ec);
234 win_iocp_thread_info this_thread;
235 thread_call_stack::context ctx(this, this_thread);
237 return do_one(usec < 0 ? INFINITE : ((usec - 1) / 1000 + 1), this_thread, ec);
249 win_iocp_thread_info this_thread;
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | scheduler.ipp | 197 thread_info this_thread;
198 this_thread.private_outstanding_work = 0;
199 thread_call_stack::context ctx(this, this_thread);
204 for (; do_run_one(lock, this_thread, ec); lock.lock())
219 thread_info this_thread;
220 this_thread.private_outstanding_work = 0;
221 thread_call_stack::context ctx(this, this_thread);
225 return do_run_one(lock, this_thread, ec);
237 thread_info this_thread;
238 this_thread.private_outstanding_work = 0;
[all …]
|
| D | win_iocp_io_context.ipp | 200 win_iocp_thread_info this_thread;
201 thread_call_stack::context ctx(this, this_thread);
204 while (do_one(INFINITE, this_thread, ec))
219 win_iocp_thread_info this_thread;
220 thread_call_stack::context ctx(this, this_thread);
222 return do_one(INFINITE, this_thread, ec);
234 win_iocp_thread_info this_thread;
235 thread_call_stack::context ctx(this, this_thread);
237 return do_one(usec < 0 ? INFINITE : ((usec - 1) / 1000 + 1), this_thread, ec);
249 win_iocp_thread_info this_thread;
[all …]
|
| /third_party/boost/libs/thread/test/sync/futures/async/ |
| D | async_executor_pass.cpp | 53 boost::this_thread::sleep_for(ms(200)); in doit()
58 boost::this_thread::sleep_for(ms(200)); in operator ()()
87 boost::this_thread::sleep_for(ms(200)); in operator ()()
105 boost::this_thread::sleep_for(ms(200)); in f0()
113 boost::this_thread::sleep_for(ms(200)); in f1()
119 boost::this_thread::sleep_for(ms(200)); in f2()
124 boost::this_thread::sleep_for(ms(200)); in f3_0()
130 boost::this_thread::sleep_for(ms(200)); in f3_1()
137 boost::this_thread::sleep_for(ms(200)); in f3()
145 boost::this_thread::sleep_for(ms(200)); in f4()
[all …]
|
| D | async_pass.cpp | 56 boost::this_thread::sleep_for(ms(200)); in doit()
61 boost::this_thread::sleep_for(ms(200)); in operator ()()
90 boost::this_thread::sleep_for(ms(200)); in operator ()()
108 boost::this_thread::sleep_for(ms(200)); in f0()
116 boost::this_thread::sleep_for(ms(200)); in f1()
122 boost::this_thread::sleep_for(ms(200)); in f2()
127 boost::this_thread::sleep_for(ms(200)); in f3_0()
133 boost::this_thread::sleep_for(ms(200)); in f3_1()
140 boost::this_thread::sleep_for(ms(200)); in f3()
148 boost::this_thread::sleep_for(ms(200)); in f4()
[all …]
|
| /third_party/flutter/skia/third_party/externals/sdl/src/thread/generic/ |
| D | SDL_sysmutex.c | 78 SDL_threadID this_thread; in SDL_LockMutex()
84 this_thread = SDL_ThreadID(); in SDL_LockMutex()
85 if (mutex->owner == this_thread) { in SDL_LockMutex()
93 mutex->owner = this_thread; in SDL_LockMutex()
109 SDL_threadID this_thread; in SDL_TryLockMutex()
115 this_thread = SDL_ThreadID(); in SDL_TryLockMutex()
116 if (mutex->owner == this_thread) { in SDL_TryLockMutex()
125 mutex->owner = this_thread; in SDL_TryLockMutex()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/thread/pthread/ |
| D | SDL_sysmutex.c | 87 pthread_t this_thread; in SDL_LockMutex() local
95 this_thread = pthread_self(); in SDL_LockMutex()
96 if (mutex->owner == this_thread) { in SDL_LockMutex()
104 mutex->owner = this_thread; in SDL_LockMutex()
123 pthread_t this_thread; in SDL_TryLockMutex() local
132 this_thread = pthread_self(); in SDL_TryLockMutex()
133 if (mutex->owner == this_thread) { in SDL_TryLockMutex()
141 mutex->owner = this_thread; in SDL_TryLockMutex()
|
| /third_party/boost/libs/thread/example/ |
| D | serial_executor.cpp | 31 boost::this_thread::sleep_for(boost::chrono::milliseconds(30)); in p1()
38 boost::this_thread::sleep_for(boost::chrono::milliseconds(10)); in p2()
45 boost::this_thread::sleep_for(boost::chrono::seconds(1)); in f1()
51 boost::this_thread::sleep_for(boost::chrono::seconds(2)); in f2()
85 boost::this_thread::sleep_for(boost::chrono::seconds(10)); in test_executor_adaptor()
|
| D | serial_executor_cont.cpp | 31 boost::this_thread::sleep_for(boost::chrono::milliseconds(30)); in p1()
38 boost::this_thread::sleep_for(boost::chrono::milliseconds(10)); in p2()
45 boost::this_thread::sleep_for(boost::chrono::seconds(1)); in f1()
51 boost::this_thread::sleep_for(boost::chrono::seconds(2)); in f2()
89 boost::this_thread::sleep_for(boost::chrono::seconds(10)); in test_executor_adaptor()
|
| D | default_executor.cpp | 35 boost::this_thread::sleep_for(boost::chrono::milliseconds(200)); in p2()
43 boost::this_thread::sleep_for(boost::chrono::milliseconds(200)); in p1()
45 boost::this_thread::sleep_for(boost::chrono::milliseconds(400)); in p1()
55 boost::this_thread::sleep_for(boost::chrono::seconds(5)); in main()
|
| D | thread_pool.cpp | 29 << boost::this_thread::get_id() << " P1" << BOOST_THREAD_END_LOG; in p1()
35 << boost::this_thread::get_id() << " P2" << BOOST_THREAD_END_LOG; in p2()
55 << boost::this_thread::get_id() << " <MAIN" << BOOST_THREAD_END_LOG; in main()
76 << boost::this_thread::get_id() << "MAIN>" << BOOST_THREAD_END_LOG; in main()
|
| D | user_scheduler.cpp | 27 << boost::this_thread::get_id() << " P1" << BOOST_THREAD_END_LOG; in p1()
33 << boost::this_thread::get_id() << " P2" << BOOST_THREAD_END_LOG; in p2()
52 << boost::this_thread::get_id() << " <MAIN" << BOOST_THREAD_END_LOG; in main()
77 << boost::this_thread::get_id() << "MAIN>" << BOOST_THREAD_END_LOG; in main()
|
| /third_party/boost/boost/thread/ |
| D | testable_mutex.hpp | 53 id_ = this_thread::get_id(); in lock()
68 id_ = this_thread::get_id(); in try_lock()
83 id_ = this_thread::get_id(); in try_lock_for()
97 id_ = this_thread::get_id(); in try_lock_until()
109 return this_thread::get_id() == id_; in is_locked_by_this_thread()
|
| /third_party/boost/boost/thread/pthread/ |
| D | shared_mutex.hpp | 171 boost::this_thread::disable_interruption do_not_disturb; in lock_shared()
194 boost::this_thread::disable_interruption do_not_disturb; in timed_lock_shared()
209 boost::this_thread::disable_interruption do_not_disturb; in timed_lock_shared()
230 boost::this_thread::disable_interruption do_not_disturb; in try_lock_shared_until()
269 boost::this_thread::disable_interruption do_not_disturb; in lock()
281 boost::this_thread::disable_interruption do_not_disturb; in timed_lock()
299 boost::this_thread::disable_interruption do_not_disturb; in timed_lock()
323 boost::this_thread::disable_interruption do_not_disturb; in try_lock_until()
362 boost::this_thread::disable_interruption do_not_disturb; in lock_upgrade()
374 boost::this_thread::disable_interruption do_not_disturb; in timed_lock_upgrade()
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | scheduler_test.cpp | 116 auto threadID = std::this_thread::get_id(); in TEST_P()
118 ASSERT_EQ(threadID, std::this_thread::get_id()); in TEST_P()
123 std::this_thread::sleep_for(std::chrono::milliseconds(10)); in TEST_P()
143 auto threadID = std::this_thread::get_id(); in TEST_P()
145 ASSERT_EQ(threadID, std::this_thread::get_id()); in TEST_P()
150 std::this_thread::sleep_for(std::chrono::milliseconds(10)); in TEST_P()
175 threads.emplace(std::this_thread::get_id()); in TEST_F()
181 ASSERT_EQ(threads.count(std::this_thread::get_id()), 0U); in TEST_F()
|
| /third_party/boost/libs/config/test/ |
| D | boost_no_cxx11_hdr_thread.ipp | 20 using std::this_thread::get_id;
21 using std::this_thread::yield;
22 using std::this_thread::sleep_until;
23 using std::this_thread::sleep_for;
|
| /third_party/flutter/skia/third_party/externals/sdl/src/thread/psp/ |
| D | SDL_sysmutex.c | 80 SDL_threadID this_thread; in SDL_mutexP()
86 this_thread = SDL_ThreadID(); in SDL_mutexP()
87 if (mutex->owner == this_thread) { in SDL_mutexP()
95 mutex->owner = this_thread; in SDL_mutexP()
|