- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 159 for Runnable (0.39 sec)
-
guava-testlib/test/com/google/common/testing/anotherpackage/ForwardingWrapperTesterTest.java
tester.testForwarding( Runnable.class, new Function<Runnable, Runnable>() { @Override public Runnable apply(final Runnable runnable) { return new ForwardingRunnable(runnable); } }); } public void testToStringForwarding() { tester.testForwarding( Runnable.class, new Function<Runnable, Runnable>() { @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 15.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
try { final SequentialExecutor executor = new SequentialExecutor(service); Runnable errorTask = new Runnable() { @Override public void run() { throw new MyError(); } }; Runnable barrierTask = new Runnable() { @Override public void run() { try {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/anotherpackage/ForwardingWrapperTesterTest.java
tester.testForwarding( Runnable.class, new Function<Runnable, Runnable>() { @Override public Runnable apply(final Runnable runnable) { return new ForwardingRunnable(runnable); } }); } public void testToStringForwarding() { tester.testForwarding( Runnable.class, new Function<Runnable, Runnable>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 15.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ThrowingRunnable runnable = new ThrowingRunnable(5, ex); future = service.scheduleAtFixedRate(runnable, 1, 1, TimeUnit.MILLISECONDS); assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); runnable = new ThrowingRunnable(5, ex); future = service.scheduleWithFixedDelay(runnable, 1, 1, TimeUnit.MILLISECONDS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
try { final SequentialExecutor executor = new SequentialExecutor(service); Runnable errorTask = new Runnable() { @Override public void run() { throw new MyError(); } }; Runnable barrierTask = new Runnable() { @Override public void run() { try {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
enum WorkerRunningState { /** Runnable is not running and not queued for execution */ IDLE, /** Runnable is not running, but is being queued for execution */ QUEUING, /** runnable has been submitted but has not yet begun execution */ QUEUED, RUNNING, } /** Underlying executor that all submitted Runnable objects are run on. */ private final Executor executor;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances // and DONE/INTERRUPTED - they have a common ancestor of Runnable. abstract class InterruptibleTask<T extends @Nullable Object> extends AtomicReference<@Nullable Runnable> implements Runnable { static { // Prevent rare disastrous classloading in first call to LockSupport.park. // See: https://bugs.openjdk.java.net/browse/JDK-8074773
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java
} @CanIgnoreReturnValue public B withSetUp(Runnable setUp) { this.setUp = setUp; return self(); } public Runnable getSetUp() { return setUp; } @CanIgnoreReturnValue public B withTearDown(Runnable tearDown) { this.tearDown = tearDown; return self(); } public Runnable getTearDown() { return tearDown; } // Features
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 10.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* otherwise-concurrent GC cycle. */ private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState> implements Executor, Runnable { /** * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run * or queued. */ @CheckForNull ExecutionSequencer sequencer; /**
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) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
*/ @J2ktIncompatible @GwtIncompatible // concurrency static Thread newThread(String name, Runnable runnable) { checkNotNull(name); checkNotNull(runnable); // TODO(b/139726489): Confirm that null is impossible here. Thread result = requireNonNull(platformThreadFactory().newThread(runnable)); try { result.setName(name); } catch (SecurityException e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0)