| /packages/apps/Launcher2/src/com/android/launcher2/ |
| DeferredHandler.java | 35 private LinkedList<Runnable> mQueue = new LinkedList();
42 synchronized (mQueue) {
43 if (mQueue.size() == 0) {
46 r = mQueue.removeFirst();
49 synchronized (mQueue) {
77 synchronized (mQueue) {
78 mQueue.add(runnable);
79 if (mQueue.size() == 1) {
91 synchronized (mQueue) {
92 while (mQueue.remove(runnable)) {
[all...] |
| /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 if (mQueue.isEmpty()) {
51 Runnable command = mQueue.removeFirst();
|
| /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/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();
|
| /frameworks/base/core/java/android/os/ |
| Looper.java | 59 final MessageQueue mQueue;
88 myLooper().mQueue.mQuitAllowed = false;
108 MessageQueue queue = me.mQueue;
159 return myLooper().mQueue;
163 mQueue = new MessageQueue();
173 mQueue.enqueueMessage(msg, 0);
187 pw.println(prefix + "mQueue=" + ((mQueue != null) ? mQueue : "(null"));
188 if (mQueue != null)
[all...] |
| Handler.java | 124 mQueue = mLooper.mQueue;
148 mQueue = mLooper.mQueue;
157 mQueue = looper.mQueue;
167 mQueue = looper.mQueue;
344 mQueue.removeMessages(this, r, null);
353 mQueue.removeMessages(this, r, token)
[all...] |
| /packages/apps/Camera/src/com/android/camera/gallery/ |
| LruCache.java | 34 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>();
57 Entry<K, V> entry = (Entry<K, V>) mQueue.poll();
60 entry = (Entry<K, V>) mQueue.poll();
68 key, new Entry<K, V>(key, value, mQueue));
83 mQueue = new ReferenceQueue<V>();
|
| ImageListUber.java | 35 private final PriorityQueue<MergeSlot> mQueue;
51 mQueue = new PriorityQueue<MergeSlot>(4,
59 mQueue.clear();
63 if (slot.next()) mQueue.add(slot);
116 if (slot.next()) mQueue.add(slot);
119 if (slot.next()) mQueue.add(slot);
124 MergeSlot slot = mQueue.poll();
|
| /packages/apps/Gallery/src/com/android/camera/gallery/ |
| LruCache.java | 30 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>();
53 Entry<K, V> entry = (Entry<K, V>) mQueue.poll();
56 entry = (Entry<K, V>) mQueue.poll();
64 key, new Entry<K, V>(key, value, mQueue));
79 mQueue = new ReferenceQueue<V>();
|
| ImageListUber.java | 39 private final PriorityQueue<MergeSlot> mQueue;
55 mQueue = new PriorityQueue<MergeSlot>(4,
63 mQueue.clear();
67 if (slot.next()) mQueue.add(slot);
136 if (slot.next()) mQueue.add(slot);
139 if (slot.next()) mQueue.add(slot);
144 MergeSlot slot = mQueue.poll();
234 if (slot.next()) mQueue.add(slot);
237 if (slot.next()) mQueue.add(slot);
|
| /frameworks/base/media/libstagefright/ |
| TimedEventQueue.cpp | 83 mQueue.clear();
111 List<QueueItem>::iterator it = mQueue.begin();
112 while (it != mQueue.end() && realtime_us >= (*it).realtime_us) {
120 if (it == mQueue.begin()) {
124 mQueue.insert(it, item);
164 List<QueueItem>::iterator it = mQueue.begin();
165 while (it != mQueue.end()) {
171 if (it == mQueue.begin()) {
178 it = mQueue.erase(it);
234 while (mQueue.empty())
[all...] |
| AwesomePlayer.cpp | 212 mQueue.stop();
221 mQueue.cancelEvent(mVideoEvent->eventID());
223 mQueue.cancelEvent(mStreamDoneEvent->eventID());
225 mQueue.cancelEvent(mCheckAudioStatusEvent->eventID());
229 mQueue.cancelEvent(mBufferingEvent->eventID());
984 mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs);
994 mQueue.postEvent(mStreamDoneEvent);
1006 mQueue.postEventWithDelay(mBufferingEvent, 1000000ll);
1014 mQueue.postEventWithDelay(mCheckAudioStatusEvent, 100000ll);
1092 mQueue.start()
[all...] |
| /dalvik/tests/079-phantom/src/ |
| Bitmap.java | 126 ReferenceQueue<PhantomWrapper> mQueue;
130 mQueue = queue;
137 PhantomWrapper ref = (PhantomWrapper) mQueue.remove();
|
| /packages/apps/Calendar/src/com/android/calendar/ |
| EventLoader.java | 151 LinkedBlockingQueue<LoadRequest> mQueue;
155 mQueue = queue;
161 mQueue.put(new ShutdownRequest());
176 LoadRequest request = mQueue.take();
180 while (!mQueue.isEmpty()) {
185 request = mQueue.take();
|
| /frameworks/base/media/libstagefright/include/ |
| TimedEventQueue.h | 112 List<QueueItem> mQueue;
|
| AwesomePlayer.h | 107 TimedEventQueue mQueue;
|
| /frameworks/base/media/libstagefright/omx/ |
| OMX.cpp | 59 List<omx_message> mQueue;
99 mQueue.push_back(msg);
128 while (!mDone && mQueue.empty()) {
136 msg = *mQueue.begin();
137 mQueue.erase(mQueue.begin());
|
| /packages/apps/IM/src/com/android/im/app/ |
| ImApp.java | 80 ArrayList<Message> mQueue = new ArrayList<Message>();
233 synchronized (mQueue) {
234 for (Message msg : mQueue) {
237 mQueue.clear();
507 synchronized (mQueue) {
508 mQueue.add(msg);
514 synchronized (mQueue) {
515 Iterator<Message> iter = mQueue.iterator();
|
| /frameworks/base/services/java/com/android/server/status/ |
| StatusBarService.java | 157 ArrayList<PendingOp> mQueue = new ArrayList<PendingOp>();
451 mQueue.add(op);
452 if (mQueue.size() == 1) {
464 mQueue.add(op);
465 if (mQueue.size() == 1) {
476 mQueue.add(op);
477 if (mQueue.size() == 1) {
564 queue = mQueue;
565 mQueue = new ArrayList<PendingOp>();
[all...] |
| /external/opencore/nodes/pvmp4ffcomposernode/src/ |
| pvmp4ffcn_node.cpp | 95 mQueue.reserve(FRAME_QUEUE_DEFAULT_SIZE);
103 LOGD_IF(!mQueue.empty(), "Releasing %d fragments in dtor", mQueue.size());
105 while (!mQueue.empty()) // make sure we are flushed
107 releaseQueuedFrame(mQueue.begin());
133 done = mQueue.empty();
167 mQueue.push_back(frame);
200 mQueue.erase(frame);
216 if (mQueue.empty())
219 if (!mQueue.empty())
[all...] |
| /frameworks/base/services/java/com/android/server/ |
| BackupManagerService.java | [all...] |
| WindowManagerService.java | 499 final KeyQ mQueue;
653 mQueue = new KeyQ();
[all...] |
