| /libcore/ojluni/src/main/java/java/nio/file/ |
| WatchService.java | 43 * {@link #poll() poll} or {@link #take() take} methods to retrieve keys
113 * <p> If a thread is currently blocked in the {@link #take take} or {@link
173 WatchKey take() throws InterruptedException; method in interface:WatchService
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| CompletionService.java | 41 * {@code submit} tasks for execution. Consumers {@code take}
59 * actions following a successful return from the corresponding {@code take()}.
98 Future<V> take() throws InterruptedException; method in interface:CompletionService
|
| BlockingQueue.java | 81 * <td>{@link #take take()}</td>
152 * while (true) { consume(queue.take()); }
263 E take() throws InterruptedException; method in interface:BlockingQueue
|
| ExecutorCompletionService.java | 41 * upon completion, placed on a queue accessible using {@code take}.
65 * Result r = ecs.take().get();
89 * Result r = ecs.take().get();
194 public Future<V> take() throws InterruptedException { method in class:ExecutorCompletionService
195 return completionQueue.take();
|
| /external/testng/src/main/java/org/testng/internal/ |
| PoolService.java | 48 Future<FutureType> take = m_completionService.take(); local
49 result.add(take.get());
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| SegmentPool.java | 36 static Segment take() { method in class:SegmentPool
|
| /prebuilts/clang/host/darwin-x86/clang-4579689/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/darwin-x86/clang-4630689/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/darwin-x86/clang-4639204/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/darwin-x86/clang-4691093/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/linux-x86/clang-4579689/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/linux-x86/clang-4630689/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/linux-x86/clang-4639204/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /prebuilts/clang/host/linux-x86/clang-4691093/include/clang/Basic/ |
| DiagnosticError.h | 40 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { function in class:clang::DiagnosticError
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ForwardingBlockingQueue.java | 71 @Override public E take() throws InterruptedException { method in class:ForwardingBlockingQueue
72 return delegate().take();
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| IntQueue.java | 45 int take() { method in class:IntQueue
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| TestLogHandler.java | 41 public synchronized String take() throws InterruptedException { method in class:TestLogHandler
|
| /frameworks/av/media/libstagefright/webm/ |
| LinkedBlockingQueue.h | 67 T take() { function in class:android::LinkedBlockingQueue
|
| /frameworks/base/core/java/android/view/ |
| DragAndDropPermissions.java | 80 * Take the permissions and bind their lifetime to the activity.
85 public boolean take(IBinder activityToken) { method in class:DragAndDropPermissions
87 mDragAndDropPermissions.take(activityToken);
95 * Take the permissions. Must call {@link #release} explicitly.
|
| /external/guava/guava/src/com/google/common/collect/ |
| ForwardingBlockingDeque.java | 105 public E take() throws InterruptedException { method in class:ForwardingBlockingDeque
106 return delegate().take();
|
| /external/swiftshader/third_party/LLVM/include/llvm/ADT/ |
| OwningPtr.h | 25 /// pointee object can be taken away from OwningPtr by using the take method.
48 /// take - Reset the owning pointer to null and return its pointer. This does
50 T *take() { function in class:llvm::OwningPtr
102 /// take - Reset the owning pointer to null and return its pointer. This does
104 T *take() { function in class:llvm::OwningArrayPtr
|
| /external/volley/src/test/java/com/android/volley/mock/ |
| WaitableQueue.java | 34 // TODO: this isn't really "until empty" it's "until next call to take() after empty"
44 public Request<?> take() throws InterruptedException { method in class:WaitableQueue
45 Request<?> item = super.take();
48 return take();
|
| /external/swiftshader/third_party/LLVM/lib/Support/Windows/ |
| Windows.h | 79 HandleType take() { function in class:ScopedHandle
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| barrier_ops_test.py | 285 def take(): function in function:BarrierTest.testBlockingTakeMany
292 t = self.checkedThread(target=take)
318 def take(sess, i, taken): function in function:BarrierTest.testParallelInsertManyTakeMany
336 target=take, args=(sess, i, taken)) for i in range(num_iterations)
522 def take(sess, i, taken): function in function:BarrierTest._testParallelInsertManyTakeManyCloseHalfwayThrough
542 target=take, args=(sess, i, taken)) for i in range(num_iterations)
606 def take(sess, i, taken): function in function:BarrierTest._testParallelPartialInsertManyTakeManyCloseHalfwayThrough
640 target=take, args=(sess, i, taken)) for i in range(num_iterations)
|
| /frameworks/base/services/core/java/com/android/server/ |
| InputContentUriTokenHandler.java | 59 public void take() { method in class:InputContentUriTokenHandler
|
