/external/libcxx/test/std/utilities/function.objects/bind/func.bind/func.bind.bind/ |
H A D | copy.pass.cpp | 31 auto task = std::bind(fnc, 2.f, 4.f); local 32 auto task2(task); 33 assert(task() == 16);
|
/external/valgrind/none/tests/darwin/ |
H A D | bug254164.c | 13 #include <mach/task.h> 16 void getres(task_t task, unsigned int *rss, unsigned int *vs) argument 21 task_info(task, TASK_BASIC_INFO, (task_info_t)&t_info, &t_info_count); 27 * Per comments in osfmk/kern/task.c: 35 void setres(task_t task) 44 task_set_info(task, TASK_TRACE_MEMORY_INFO, (task_info_t)&t_info, &t_info_count); 51 task_t task = MACH_PORT_NULL; local 53 if (task_for_pid(current_task(), getpid(), &task) != KERN_SUCCESS) 56 getres(task, &rss, &vs); 57 //setres(task); [all...] |
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ForwardingListeningExecutorService.java | 39 public <T> ListenableFuture<T> submit(Callable<T> task) { argument 40 return delegate().submit(task); 44 public ListenableFuture<?> submit(Runnable task) { argument 45 return delegate().submit(task); 49 public <T> ListenableFuture<T> submit(Runnable task, T result) { argument 50 return delegate().submit(task, result);
|
H A D | AbstractListeningExecutorService.java | 48 public ListenableFuture<?> submit(Runnable task) { argument 49 ListenableFutureTask<Void> ftask = ListenableFutureTask.create(task, null); 55 public <T> ListenableFuture<T> submit(Runnable task, @Nullable T result) { argument 56 ListenableFutureTask<T> ftask = ListenableFutureTask.create(task, result); 62 public <T> ListenableFuture<T> submit(Callable<T> task) { argument 63 ListenableFutureTask<T> ftask = ListenableFutureTask.create(task);
|
H A D | Callables.java | 82 * @param task The Runnable to wrap 86 static Runnable threadRenaming(final Runnable task, final Supplier<String> nameSupplier) { argument 88 checkNotNull(task); 95 task.run();
|
H A D | ListeningExecutorService.java | 37 * @return a {@code ListenableFuture} representing pending completion of the task 41 <T> ListenableFuture<T> submit(Callable<T> task); argument 44 * @return a {@code ListenableFuture} representing pending completion of the task 48 ListenableFuture<?> submit(Runnable task); argument 51 * @return a {@code ListenableFuture} representing pending completion of the task 55 <T> ListenableFuture<T> submit(Runnable task, T result); argument 68 * sequential order as produced by the iterator for the given task list, each of which has 71 * @throws NullPointerException if any task is null 88 * sequential order as produced by the iterator for the given task list. If the operation 89 * did not time out, each task wil [all...] |
H A D | WrappingScheduledExecutorService.java | 27 * <p>Note that task wrapping may occur even if the task is never executed. 46 public final <V> ScheduledFuture<V> schedule(Callable<V> task, long delay, TimeUnit unit) { argument 47 return delegate.schedule(wrapTask(task), delay, unit);
|
/external/v8/src/libplatform/ |
H A D | default-platform-unittest.cc | 34 StrictMock<MockTask>* task = new StrictMock<MockTask>; local 35 platform.CallOnForegroundThread(isolate, task); 36 EXPECT_CALL(*task, Run()); 37 EXPECT_CALL(*task, Die());
|
H A D | task-queue-unittest.cc | 7 #include "src/libplatform/task-queue.h" 40 MockTask task; local 41 queue.Append(&task); 42 EXPECT_EQ(&task, queue.GetNext());
|
H A D | task-queue.cc | 5 #include "src/libplatform/task-queue.h" 22 void TaskQueue::Append(Task* task) { argument 25 task_queue_.push(task);
|
H A D | worker-thread-unittest.cc | 6 #include "src/libplatform/task-queue.h" 34 StrictMock<MockTask>* task = new StrictMock<MockTask>; local 35 EXPECT_CALL(*task, Run()); 36 EXPECT_CALL(*task, Die()); 37 queue.Append(task);
|
H A D | default-platform.cc | 81 Task* task = NULL; local 89 task = it->second.front(); 92 task->Run(); 93 delete task; 97 void DefaultPlatform::CallOnBackgroundThread(Task *task, argument 100 queue_.Append(task); 104 void DefaultPlatform::CallOnForegroundThread(v8::Isolate* isolate, Task* task) { argument 106 main_thread_queue_[isolate].push(task);
|
/external/apache-xml/src/main/java/org/apache/xml/utils/ |
H A D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) argument 41 m_tpool.waitThread(worker, task); 54 * Will get a thread from the pool, execute the task 60 * NEEDSDOC @param task 61 * @param priority if >0 the task will run with the given priority 63 * @return The thread that is running the task, can be used 66 public Thread run(Runnable task, int priority) argument 69 Thread t = new Thread(task); 79 * Wait until the task is completed on the worker 83 * NEEDSDOC @param task 87 waitThread(Thread worker, Runnable task) argument [all...] |
/external/emma/ant/ant14/com/vladium/emma/ant/ |
H A D | GenericCfg.java | 41 public GenericCfg (final Task task) argument 43 if (task == null) throw new IllegalArgumentException ("null input: task"); 45 m_task = task;
|
H A D | StringValue.java | 47 protected StringValue (final Task task) argument 49 if (task == null) throw new IllegalArgumentException ("null input: task"); 51 m_task = task;
|
/external/emma/ant/ant14/com/vladium/emma/ |
H A D | emmaTask.java | 50 final NestedTask task = (NestedTask) m_tasks.remove (0); 55 setTaskName (task.getTaskName ()); 57 task.execute (); 86 protected NestedTask addTask (final NestedTask task, final String pseudoName) argument 88 initTask (task, pseudoName); 90 m_tasks.add (task); 91 return task; 94 protected void initTask (final NestedTask task, final String pseudoName) argument 96 task.setTaskName (pseudoName); 97 task [all...] |
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
H A D | AbstractExecutorService.java | 17 public Future<?> submit(Runnable task) { argument 18 if (task == null) throw new NullPointerException(); 19 FutureTask<Object> ftask = new FutureTask<Object>(task, null); 24 public <T> Future<T> submit(Runnable task, T result) { argument 25 if (task == null) throw new NullPointerException(); 26 FutureTask<T> ftask = new FutureTask<T>(task, result); 31 public <T> Future<T> submit(Callable<T> task) { argument 32 if (task == null) throw new NullPointerException(); 33 FutureTask<T> ftask = new FutureTask<T>(task);
|
H A D | ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); argument 30 <T> Future<T> submit(Runnable task, T result); argument 32 Future<?> submit(Runnable task); argument
|
/external/guava/guava-tests/test/com/google/common/cache/ |
H A D | CacheLoaderTest.java | 43 public void execute(Runnable task) { argument 44 tasks.add(task);
|
/external/guava/guava-tests/test/com/google/common/eventbus/ |
H A D | AsyncEventBusTest.java | 55 // Now we find the task in our Executor and explicitly activate it. 57 assertEquals("One event dispatch task should be queued.", 1, tasks.size()); 76 public void execute(Runnable task) { argument 77 tasks.add(task);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | ListenableFutureTaskTest.java | 43 protected final ListenableFutureTask<Integer> task = field in class:ListenableFutureTaskTest 62 task.addListener(new Runnable() { 83 assertFalse(task.isDone()); 84 assertFalse(task.isCancelled()); 86 // Start the task to put it in the RUNNING state. Have to use a separate 87 // thread because the task will block on the task latch after unblocking 89 exec.execute(task); 92 assertFalse(task.isDone()); 93 assertFalse(task [all...] |
/external/jetty/src/java/org/eclipse/jetty/io/ |
H A D | AsyncEndPoint.java | 77 public void scheduleTimeout(Timeout.Task task, long timeoutMs); argument 82 public void cancelTimeout(Timeout.Task task); argument
|
/external/lldb/tools/debugserver/source/MacOSX/ |
H A D | MachVMRegion.cpp | 19 MachVMRegion::MachVMRegion(task_t task) : argument 20 m_task(task), 68 DNBLogThreadedIf(LOG_MEMORY_PROTECTIONS | LOG_VERBOSE, "MachVMRegion::%s: protections (%u) already sufficient for task 0x%4.4x at address 0x%8.8llx) ", __FUNCTION__, prot, m_task, (uint64_t)addr); 76 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)addr, (uint64_t)prot_size, 0, prot); 82 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)addr, (uint64_t)prot_size, 0, prot | VM_PROT_COPY); 95 DNBLogThreadedIf(LOG_MEMORY_PROTECTIONS | LOG_VERBOSE, "%s: Zero size for task 0x%4.4x at address 0x%8.8llx) ", __FUNCTION__, m_task, (uint64_t)addr); 108 m_err.LogThreaded("::mach_vm_protect ( task = 0x%4.4x, addr = 0x%8.8llx, size = %llu, set_max = %i, prot = %u )", m_task, (uint64_t)m_protection_addr, (uint64_t)m_protection_size, 0, m_data.protection); 143 m_err.LogThreaded("::mach_vm_region_recurse ( task = 0x%4.4x, address => 0x%8.8llx, size => %llu, nesting_depth => %d, info => %p, infoCnt => %d) addr = 0x%8.8llx ", m_task, (uint64_t)m_start, (uint64_t)m_size, m_depth, &m_data, info_size, (uint64_t)addr);
|
/external/skia/tools/timer/ |
H A D | SysTimer_mach.cpp | 10 mach_port_t task = mach_task_self(); local 11 if (task == MACH_PORT_NULL) { 18 if (KERN_SUCCESS != task_info(task,
|
/external/emma/ant/ant14/com/vladium/emma/instr/ |
H A D | FilterCfg.java | 38 public filterElement (final Task task) argument 40 super (task); 118 public FilterCfg (final Task task) argument 120 if (task == null) throw new IllegalArgumentException ("null input: task"); 122 m_task = task;
|