- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for Command (0.15 sec)
-
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override @CanIgnoreReturnValue public List<Runnable> shutdownNow() { return delegate().shutdownNow(); } @Override public void execute(Runnable command) { delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate().submit(task); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
private static class FakeExecutor implements Executor { Queue<Runnable> tasks = Queues.newArrayDeque(); @Override public void execute(Runnable command) { tasks.add(command); } boolean hasNext() { return !tasks.isEmpty(); } void runNext() { assertTrue("expected at least one task to run", hasNext()); tasks.remove().run();
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-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
public void testTimeout() throws Exception { // Create a service whose executor will never run its commands Service service = new TestService() { @Override protected Executor executor() { return new Executor() { @Override public void execute(Runnable command) {} }; } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command); wasExecuted = true; } } public void testTransform_Executor() throws Exception { Object value = new Object(); ExecutorSpy spy = new ExecutorSpy(directExecutor());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/Crc32cHashFunctionTest.java
for (int i = 0; i < 100; i++) { descending[i] = (byte) (99 - i); } assertCrc(0xd022db97, descending); } public void testScsiReadCommand() { // Test SCSI read command. byte[] scsiReadCommand = new byte[] { 0x01, (byte) 0xc0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Dec 23 18:30:33 GMT 2020 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
Executor delegate; boolean wasExecuted; public ExecutorSpy(Executor delegate) { this.delegate = delegate; } @Override public void execute(Runnable command) { delegate.execute(command); wasExecuted = true; } } public void testTransform_Executor() throws Exception { Object value = new Object(); ExecutorSpy spy = new ExecutorSpy(directExecutor());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java
public void testScheduleRunnable() throws Exception { Runnable command = () -> {}; ListenableScheduledFuture<?> future = executorService.schedule(command, Duration.ofSeconds(12)); assertThat(future.get()).isEqualTo("schedule"); assertThat(recordedCommand).isSameInstanceAs(command); assertThat(recordedTimeUnit).isEqualTo(TimeUnit.NANOSECONDS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Mar 17 20:45:59 GMT 2020 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
@J2ObjCIncompatible public static File createTempDir() { return TempFileCreator.INSTANCE.createTempDir(); } /** * Creates an empty file or updates the last updated timestamp on the same as the unix command of * the same name. * * @param file the file to create or update * @throws IOException if an I/O error occurs */ @SuppressWarnings("GoodTime") // reading system time without TimeSource
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 33.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
@Override protected <T> Callable<T> wrapTask(Callable<T> callable) { return new WrappedCallable<T>(callable); } @Override protected Runnable wrapTask(Runnable command) { return new WrappedRunnable(command); } } private static final class MockExecutor implements ScheduledExecutorService { String lastMethodCalled = ""; long lastInitialDelay; long lastDelay;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 7.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
return new Thread(r); } } public static final class DummyExecutor implements Executor, Serializable { @Override public void execute(Runnable command) {} } } private static final class NullByteSink extends ByteSink implements Serializable { private static final NullByteSink INSTANCE = new NullByteSink(); @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 21K bytes - Viewed (1)