OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:waiters_
(Results
1 - 9
of
9
) sorted by null
/external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/
SimpleThreadPool.h
25
: env_(env), threads_(num_threads),
waiters_
(num_threads) {
43
for (auto w :
waiters_
) {
61
if (
waiters_
.empty()) {
64
Waiter* w =
waiters_
.back();
65
waiters_
.pop_back();
97
waiters_
.push_back(&w);
139
MaxSizeVector<Waiter*>
waiters_
; // Stack of waiting threads.
member in class:Eigen::SimpleThreadPoolTempl
EventCount.h
53
EventCount(MaxSizeVector<Waiter>& waiters) :
waiters_
(waiters) {
93
newstate = (newstate & ~kStackMask) | (w - &
waiters_
[0]);
97
w->next.store(&
waiters_
[state & kStackMask], std::memory_order_relaxed);
148
Waiter* w = &
waiters_
[state & kStackMask];
151
if (wnext != nullptr) next = wnext - &
waiters_
[0];
162
Waiter* w = &
waiters_
[state & kStackMask];
202
MaxSizeVector<Waiter>&
waiters_
;
member in class:Eigen::EventCount
NonBlockingThreadPool.h
27
waiters_
(num_threads),
31
ec_(
waiters_
) {
32
waiters_
.resize(num_threads);
128
MaxSizeVector<EventCount::Waiter>
waiters_
;
member in class:Eigen::NonBlockingThreadPoolTempl
141
EventCount::Waiter* waiter = &
waiters_
[thread_id];
/external/libchrome/base/synchronization/
waitable_event_posix.cc
386
i = kernel_->
waiters_
.begin(); i != kernel_->
waiters_
.end(); ++i) {
391
kernel_->
waiters_
.clear();
401
if (kernel_->
waiters_
.empty())
404
const bool r = (*kernel_->
waiters_
.begin())->Fire(this);
405
kernel_->
waiters_
.pop_front();
415
kernel_->
waiters_
.push_back(waiter);
424
i =
waiters_
.begin(); i !=
waiters_
.end(); ++i) {
426
waiters_
.erase(i)
[
all
...]
waitable_event.h
255
std::list<Waiter*>
waiters_
;
member in struct:base::WaitableEvent::WaitableEventKernel
/art/openjdkjvmti/
ti_object.cc
102
for (art::Thread* thd : info.
waiters_
) {
/art/runtime/
monitor.h
390
std::vector<Thread*>
waiters_
;
member in class:art::MonitorInfo
monitor.cc
[
all
...]
debugger.cc
873
expandBufAdd4BE(reply, monitor_info.
waiters_
.size());
874
for (size_t i = 0; i < monitor_info.
waiters_
.size(); ++i) {
875
expandBufAddObjectId(reply, gRegistry->Add(monitor_info.
waiters_
[i]->GetPeerFromOtherThread()));
[
all
...]
Completed in 951 milliseconds