- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 48 for Command (1.03 sec)
-
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
addCallback(f, callback, directExecutor()); } private class CountingSameThreadExecutor implements Executor { int runCount = 0; @Override public void execute(Runnable command) { command.run(); runCount++; } } private final class MockCallback implements FutureCallback<String> { @Nullable private String value = null; @Nullable private Throwable failure = null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Nov 15 16:33:21 UTC 2022 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
*/ @GuardedBy("lock") private int runningTasks = 0; @GuardedBy("lock") private boolean shutdown = false; @Override public void execute(Runnable command) { startTask(); try { command.run(); } finally { endTask(); } } @Override public boolean isShutdown() { synchronized (lock) { return shutdown; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
} } private static final class Listener { final Runnable command; final Executor executor; Listener(Runnable command, Executor executor) { this.command = checkNotNull(command); this.executor = checkNotNull(executor); } void execute() { try { executor.execute(command); } catch (RuntimeException e) { log.log( Level.SEVERE,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
integration-tests/gradle/gradlew.bat
@rem Find java.exe if defined JAVA_HOME goto findJavaFromJavaHome set JAVA_EXE=java.exe %JAVA_EXE% -version >NUL 2>&1 if %ERRORLEVEL% equ 0 goto execute echo. echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. echo. echo Please set the JAVA_HOME variable in your environment to match the echo location of your Java installation. goto fail :findJavaFromJavaHome set JAVA_HOME=%JAVA_HOME:"=%
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jun 28 18:15:57 UTC 2023 - 2.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0) -
mvnw.cmd
@REM ---------------------------------------------------------------------------- @REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on' @echo off @REM set title of command window title %0 @REM enable echoing by setting MAVEN_BATCH_ECHO to 'on' @if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO% @REM set %HOME% to equivalent of $HOME
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 16 20:48:20 UTC 2023 - 7.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
*/ @GuardedBy("lock") private int runningTasks = 0; @GuardedBy("lock") private boolean shutdown = false; @Override public void execute(Runnable command) { startTask(); try { command.run(); } finally { endTask(); } } @Override public boolean isShutdown() { synchronized (lock) { return shutdown; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
private Throwable thrownByExecutionThread; private final Executor exceptionCatchingExecutor = new Executor() { @Override public void execute(Runnable command) { executionThread = new Thread(command); executionThread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
* Executor#execute(Runnable) execute()} method is called when this service is started and * stopped, and should return promptly. */ protected Executor executor() { return command -> MoreExecutors.newThread(threadNameSupplier.get(), command).start(); } @Override public String toString() { return serviceName() + " [" + state() + "]"; } @Override public final boolean isRunning() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 17 13:59:28 UTC 2023 - 5.3K bytes - Viewed (0) -
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
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.1K bytes - Viewed (0)