/frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
AwaitableCompletionListener.java | 33 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); 38 mQueue.put(new Object()); 49 if (mQueue.poll(timeout, unit) == null) { 55 if (mQueue.peek() != null) {
|
AwaitableErrorListener.java | 31 private final BlockingQueue<Object> mQueue = new LinkedBlockingQueue<Object>(); 46 mQueue.put(new Object()); 57 if (mQueue.poll(timeout, unit) == null) { 63 if (mQueue.peek() != null) {
|
/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/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();
|
/packages/apps/Launcher2/src/com/android/launcher2/ |
DeferredHandler.java | 34 private LinkedList<Runnable> mQueue = new LinkedList<Runnable>(); 41 synchronized (mQueue) { 42 if (mQueue.size() == 0) { 45 r = mQueue.removeFirst(); 48 synchronized (mQueue) { 76 synchronized (mQueue) { 77 mQueue.add(runnable); 78 if (mQueue.size() == 1) { 90 synchronized (mQueue) { 91 while (mQueue.remove(runnable)) { [all...] |
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/keyboard/internal/ |
PointerTrackerQueue.java | 24 private final LinkedList<PointerTracker> mQueue = new LinkedList<PointerTracker>(); 27 mQueue.add(tracker); 31 if (mQueue.lastIndexOf(tracker) < 0) { 34 final LinkedList<PointerTracker> queue = mQueue; 51 for (PointerTracker t : mQueue) { 57 mQueue.clear(); 59 mQueue.add(tracker); 64 mQueue.remove(tracker); 68 for (final PointerTracker tracker : mQueue) { 79 for (PointerTracker tracker : mQueue) { [all...] |
/frameworks/base/media/libstagefright/rtsp/ |
ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } 54 List<sp<ABuffer> > mQueue;
|
/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/media/libmediaplayerservice/nuplayer/ |
NuPlayerStreamListener.h | 65 List<QueueEntry> mQueue;
|
/packages/apps/Gallery2/src/com/android/gallery3d/util/ |
IdentityCache.java | 29 private ReferenceQueue<V> mQueue = new ReferenceQueue<V>(); 44 Entry<K, V> entry = (Entry<K, V>) mQueue.poll(); 47 entry = (Entry<K, V>) mQueue.poll(); 54 key, new Entry<K, V>(key, value, mQueue)); 66 mQueue = new ReferenceQueue<V>();
|
/frameworks/base/core/java/android/os/ |
Handler.java | 124 mQueue = mLooper.mQueue; 148 mQueue = mLooper.mQueue; 157 mQueue = looper.mQueue; 167 mQueue = looper.mQueue; 359 mQueue.removeMessages(this, r, null); 369 mQueue.removeMessages(this, r, token) [all...] |
Looper.java | 59 final MessageQueue mQueue; 88 myLooper().mQueue.mQuitAllowed = false; 110 MessageQueue queue = me.mQueue; 193 return myLooper().mQueue; 197 mQueue = new MessageQueue(); 207 mQueue.enqueueMessage(msg, 0); 219 return mQueue; 227 pw.println("mQueue=" + ((mQueue != null) ? mQueue : "(null")) [all...] |
/frameworks/base/media/libstagefright/include/ |
SimpleSoftOMXComponent.h | 52 List<BufferInfo *> mQueue;
|
TimedEventQueue.h | 112 List<QueueItem> mQueue;
|
/frameworks/base/media/libstagefright/timedtext/ |
TimedTextPlayer.h | 77 TimedEventQueue *mQueue;
|
/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);
|
/packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
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(); 73 key, new Entry<K, V>(key, value, mQueue)); 88 mQueue = new ReferenceQueue<V>();
|
/packages/apps/Calendar/src/com/android/calendar/ |
EventLoader.java | 161 LinkedBlockingQueue<LoadRequest> mQueue; 165 mQueue = queue; 171 mQueue.put(new ShutdownRequest()); 186 LoadRequest request = mQueue.take(); 190 while (!mQueue.isEmpty()) { 195 request = mQueue.take();
|
/dalvik/tests/079-phantom/src/ |
Bitmap.java | 126 ReferenceQueue<PhantomWrapper> mQueue; 130 mQueue = queue; 137 PhantomWrapper ref = (PhantomWrapper) mQueue.remove();
|
/frameworks/base/tools/layoutlib/bridge/src/android/animation/ |
AnimationThread.java | 70 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>(); 91 mQueue.add(new MessageBundle(handler, msg, uptimeMillis)); 113 MessageBundle bundle = mQueue.poll(); 142 // the next message, so mQueue will have another one. 156 } while (mListener.isCanceled() == false && mQueue.size() > 0);
|
/frameworks/base/core/java/android/speech/tts/ |
AudioPlaybackHandler.java | 46 private final PriorityBlockingQueue<ListEntry> mQueue = 96 mQueue.add(new ListEntry(SYNTHESIS_DONE, token, HIGH_PRIORITY)); 148 return (mQueue.peek() != null) || (mCurrentParams != null); 157 mQueue.add(new ListEntry(SHUTDOWN, null, HIGH_PRIORITY)); 162 mQueue.add(new ListEntry(SYNTHESIS_START, token)); 167 mQueue.add(new ListEntry(SYNTHESIS_DATA_AVAILABLE, token)); 172 mQueue.add(new ListEntry(SYNTHESIS_DONE, token)); 177 mQueue.add(new ListEntry(PLAY_AUDIO, token)); 182 mQueue.add(new ListEntry(PLAY_SILENCE, token)); 203 entry = mQueue.take() [all...] |
/frameworks/base/include/gui/ |
SurfaceTexture.h | 245 // and EGLImage) for all slots except the head of mQueue 472 // mQueue is a FIFO of queued buffers used in synchronous mode 474 Fifo mQueue;
|
/frameworks/base/include/media/stagefright/ |
SurfaceMediaSource.h | 327 // mQueue is a FIFO of queued buffers used in synchronous mode 329 Fifo mQueue;
|
/frameworks/base/media/libstagefright/omx/ |
OMX.cpp | 74 List<omx_message> mQueue; 112 mQueue.push_back(msg); 130 while (!mDone && mQueue.empty()) { 138 msg = *mQueue.begin(); 139 mQueue.erase(mQueue.begin());
|