- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 222 for Task (0.12 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
public <T> Future<T> submit(Callable<T> task) { lastMethodCalled = "submit"; assertThat(task).isInstanceOf(WrappedCallable.class); return inline.submit(task); } @Override public Future<?> submit(Runnable task) { lastMethodCalled = "submit"; assertThat(task).isInstanceOf(WrappedRunnable.class); return inline.submit(task); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
directExecutor()); // Wait for the first task to be started in the background. It will block until we explicitly // stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
directExecutor()); // Wait for the first task to be started in the background. It will block until we explicitly // stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 2.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java
} public static void execute(final Runnable task) { ForkJoinPool.commonPool().execute(() -> { final Thread currentThread = Thread.currentThread(); final ClassLoader orignal = currentThread.getContextClassLoader(); currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader()); try { task.run(); } catch (final Exception e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K bytes - Viewed (1) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void testNoOpScheduledExecutor() throws InterruptedException { taskDone = false; Runnable task = new Runnable() { @Override public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, TimeUnit.MILLISECONDS); Thread.sleep(20); assertFalse(taskDone);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectModelResolver.java
pool.shutdown(); } return true; } }; pool.submit(task); return task; }); result = future.get(); } catch (Exception e) { throw new UnresolvableModelException(e, parent.getGroupId(), parent.getArtifactId(), parent.getVersion());
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 15.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* user task -- which means that we already got past this code (or else we exited early * above)) */ // Unconditionally set; there is no risk of throwing away a queued task from another thread, // because in order for the current task to run on this executor the previous task must have // already started execution. Because each task on a TaskNonReentrantExecutor can only produce
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove(); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
throw new TimeoutException("Timeout waiting for task."); } return getValue(); } /** * Blocks until {@link #complete(Object, Throwable, int)} has been successfully called. Throws * a {@link CancellationException} if the task was cancelled, or a {@link ExecutionException} * if the task completed with an error. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0)