| /frameworks/base/packages/SystemUI/shared/src/com/android/systemui/shared/recents/model/ |
| TaskResourceLoadQueue.java | 26 private final ConcurrentLinkedQueue<Task> mQueue = new ConcurrentLinkedQueue<>();
30 if (!mQueue.contains(t)) {
31 mQueue.add(t);
43 return mQueue.poll();
48 mQueue.remove(t);
53 mQueue.clear();
58 return mQueue.isEmpty();
|
| /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
| PointerTrackerQueueTests.java | 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue();
69 assertEquals(0, mQueue.size());
70 assertEquals("[]", mQueue.toString());
74 mQueue.add(mElement1);
75 assertEquals(1, mQueue.size());
76 assertEquals("[1]", mQueue.toString());
77 mQueue.add(mElement2);
78 assertEquals(2, mQueue.size());
79 assertEquals("[1 2]", mQueue.toString());
80 mQueue.add(mElement3)
[all...] |
| /system/libhidl/base/ |
| TaskRunner.cpp | 32 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit);
36 if (mQueue) {
37 mQueue->push(nullptr);
42 if (mQueue == nullptr || !t) {
47 std::unique_lock<std::mutex> lock = mQueue->lock();
49 if (!mQueue->isInitializedLocked()) {
52 std::thread{[q = mQueue] {
61 mQueue->setInitializedLocked(true);
65 return this->mQueue->push(t);
|
| SynchronizedQueue.h | 62 std::queue<T> mQueue;
76 return !this->mQueue.empty();
79 T item = mQueue.front();
80 mQueue.pop();
90 if (mQueue.size() < mQueueLimit) {
91 mQueue.push(item);
106 return mQueue.size();
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockExecutor.java | 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>();
35 mQueue.addLast(task);
39 mQueue.clear();
48 return mQueue.size();
52 if (mQueue.isEmpty()) {
55 Runnable command = mQueue.removeFirst();
|
| /system/chre/core/include/chre/core/ |
| event_ref_queue.h | 38 return mQueue.empty();
64 ArrayQueue<Event *, kMaxPendingEvents> mQueue;
|
| /system/chre/core/ |
| event_ref_queue.cc | 31 bool pushed = mQueue.push(event);
40 CHRE_ASSERT(!mQueue.empty());
42 Event *event = mQueue.front();
43 mQueue.pop();
|
| /frameworks/support/v7/recyclerview/src/androidTest/java/androidx/recyclerview/widget/ |
| MessageQueueTest.java | 34 MessageThreadUtil.MessageQueue mQueue;
38 mQueue = new MessageThreadUtil.MessageQueue();
44 mQueue.sendMessage(MessageThreadUtil.SyncQueueItem.obtainMessage(
47 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
59 mQueue.sendMessage(obtainMessage(1, 2));
60 mQueue.sendMessage(obtainMessage(3, 4));
61 mQueue.sendMessage(obtainMessage(5, 6));
63 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
67 msg = mQueue.next();
71 msg = mQueue.next()
[all...] |
| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| ConditionPriorityBlockingQueueTest.java | 30 private ConditionPriorityBlockingQueue<Integer> mQueue;
38 mQueue = new ConditionPriorityBlockingQueue<Integer>(new IntCompare());
45 assertNull(mQueue.poll());
53 mQueue.add(one);
54 assertEquals(one, mQueue.take());
55 assertNull(mQueue.poll());
65 mQueue.add(two);
66 mQueue.add(one);
67 assertEquals(one, mQueue.take());
68 assertEquals(two, mQueue.take())
[all...] |
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| DeferredHandler.java | 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>();
43 synchronized (mQueue) {
44 if (mQueue.size() == 0) {
47 p = mQueue.removeFirst();
51 synchronized (mQueue) {
82 synchronized (mQueue) {
83 mQueue.add(new Pair<Runnable, Integer>(runnable, type));
84 if (mQueue.size() == 1) {
99 synchronized (mQueue) {
100 while (mQueue.remove(runnable)) {
[all...] |
| /packages/apps/Gallery/src/com/android/camera/ |
| ImageLoader.java | 37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>();
54 synchronized (mQueue) {
56 mQueue.add(w);
57 mQueue.notifyAll();
62 synchronized (mQueue) {
65 mQueue.remove(index);
73 // The caller should hold mQueue lock.
75 for (int i = 0; i < mQueue.size(); i++) {
76 if (mQueue.get(i).mImage == image) {
85 synchronized (mQueue) {
[all...] |
| /packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| SampleQueue.java | 25 private final LinkedList<SampleHolder> mQueue = new LinkedList<>();
34 mQueue.offer(sample);
39 SampleHolder sampleFromQueue = mQueue.poll();
55 while (!mQueue.isEmpty()) {
56 mSamplePool.releaseSample(mQueue.poll());
66 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs;
70 return mQueue.isEmpty();
|
| /system/chre/util/include/chre/util/ |
| fixed_size_blocking_queue_impl.h | 31 success = mQueue.push(element);
44 success = mQueue.push(std::move(element));
55 while (mQueue.empty()) {
59 ElementType element(std::move(mQueue.front()));
60 mQueue.pop();
67 return mQueue.empty();
73 return mQueue.size();
79 return mQueue.remove(index);
86 return mQueue[index];
93 return mQueue[index]
[all...] |
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| SingleThreadNamedTaskExecutor.java | 32 private final LinkedBlockingQueue<NamedTask> mQueue;
37 mQueue = new LinkedBlockingQueue<NamedTask>();
43 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size() + " tasks: " + mWorker.getName());
47 mQueue.clear();
53 mQueue.clear();
60 mQueue.add(task);
78 task = mQueue.take();
|
| /packages/apps/Camera2/src/com/android/camera/processing/ |
| ProcessingServiceManager.java | 52 private final LinkedList<ProcessingTask> mQueue = new LinkedList<ProcessingTask>();
79 mQueue.add(task);
80 Log.d(TAG, "Task added. Queue size now: " + mQueue.size());
96 if (!mQueue.isEmpty() && !mHoldProcessing) {
97 Log.d(TAG, "Popping a session. Remaining: " + (mQueue.size() - 1));
98 return mQueue.remove();
111 return mServiceRunning || !mQueue.isEmpty();
137 Log.d(TAG, "Resume processing. Queue size: " + mQueue.size());
140 if (!mQueue.isEmpty()) {
|
| /system/libfmq/tests/ |
| mq_test.cpp | 39 delete mQueue;
44 mQueue = new (std::nothrow) MessageQueueSync(kNumElementsInQueue);
45 ASSERT_NE(nullptr, mQueue);
46 ASSERT_TRUE(mQueue->isValid());
47 mNumMessagesMax = mQueue->getQuantumCount();
51 MessageQueueSync* mQueue = nullptr;
58 delete mQueue;
63 mQueue = new (std::nothrow) MessageQueueUnsync(kNumElementsInQueue);
64 ASSERT_NE(nullptr, mQueue);
65 ASSERT_TRUE(mQueue->isValid())
[all...] |
| msgq_test_client.cpp | 71 delete mQueue;
81 mQueue = new (std::nothrow) MessageQueueSync(in);
83 ASSERT_NE(nullptr, mQueue);
84 ASSERT_TRUE(mQueue->isValid());
85 mNumMessagesMax = mQueue->getQuantumCount();
89 MessageQueueSync* mQueue = nullptr;
96 delete mQueue;
106 mQueue = new (std::nothrow) MessageQueueUnsync(in);
108 ASSERT_NE(nullptr, mQueue);
109 ASSERT_TRUE(mQueue->isValid())
[all...] |
| /frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/ |
| BlockingQueueIntentReceiver.java | 27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1);
31 mQueue.add(intent);
35 return mQueue.poll(10, TimeUnit.SECONDS);
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| ConcurrentQueue.h | 33 while (mQueue.empty() && mIsActive) {
42 if (mQueue.empty() || !mIsActive) {
45 while (!mQueue.empty()) {
46 items.push_back(std::move(mQueue.front()));
47 mQueue.pop();
58 mQueue.push(std::move(item));
84 std::queue<T> mQueue;
108 mQueue = queue;
129 mQueue->waitForItems();
135 std::vector<T> items = mQueue->flush()
[all...] |
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| OutputPort.java | 39 private FrameQueue mQueue = null;
56 return mQueue == null || mQueue.canPush();
165 return mQueue;
169 mQueue = queue;
180 return mQueue != null;
188 if (mQueue != null) {
189 mQueue.clear();
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
| DynamicRingBuffer.java | 62 private final CountableBufferQueue<ImageProxy> mQueue;
75 mQueue = new CountableBufferQueue<>(mQueueSize, new ImageCloser());
90 // mQueue. However, for a brief moment, we acquire a ticket from
91 // mTicketPool, but have yet added it to mQueue. During this period,
103 mQueue.discardNext();
107 mQueue.update(new TicketImageProxy(image, ticket));
127 mQueue.close();
132 return mQueue.getNext();
138 return mQueue.getNext(timeout, unit);
143 return mQueue.peekNext()
[all...] |
| /frameworks/base/services/core/jni/BroadcastRadio/ |
| NativeCallbackThread.cpp | 57 if (mQueue.empty()) {
61 if (mQueue.empty()) continue;
64 task = mQueue.front();
65 mQueue.pop();
81 ALOGD_IF(!mQueue.empty(), "Skipped execution of %zu tasks", mQueue.size());
93 mQueue.push(task);
|
| /packages/apps/Nfc/nci/jni/ |
| DataQueue.cpp | 52 while (mQueue.empty() == false) {
53 tHeader* header = mQueue.front();
54 mQueue.pop_front();
62 bool retval = mQueue.empty();
91 mQueue.push_back(header);
117 tHeader* header = mQueue.front();
127 mQueue.pop_front();
|
| /frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/ |
| ASensorEventQueue.cpp | 89 size_t copy = std::min(count, mQueue.size());
91 reinterpret_cast<sensors_event_t *>(events)[i] = mQueue[i];
93 mQueue.erase(mQueue.begin(), mQueue.begin() + copy);
101 return !mQueue.empty();
110 mQueue.emplace_back();
111 sensors_event_t *sensorEvent = &mQueue[mQueue.size() - 1];
|
| /frameworks/base/libs/hwui/thread/ |
| ThreadBase.h | 37 , mQueue([this]() { mLooper->wake(); }, mLock) {}
39 WorkQueue& queue() { return mQueue; }
55 nextWakeup = mQueue.nextWakeup(lock);
66 void processQueue() { mQueue.process(); }
79 WorkQueue mQueue;
|
