- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for Runnable (0.23 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} } /** * Submits the given runnable to the given {@link Executor} catching and logging all {@linkplain * RuntimeException runtime exceptions} thrown by the executor. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exception private static void executeListener(Runnable runnable, Executor executor) { try { executor.execute(runnable);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { TrustedListenableFutureTask<@Nullable Void> task =
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun getIdleCallback ()Ljava/lang/Runnable; public final fun getMaxRequests ()I public final fun getMaxRequestsPerHost ()I public final fun queuedCalls ()Ljava/util/List; public final fun queuedCallsCount ()I public final fun runningCalls ()Ljava/util/List; public final fun runningCallsCount ()I public final fun setIdleCallback (Ljava/lang/Runnable;)V public final fun setMaxRequests (I)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
} } catch (final Exception e) { logger.warn("Failed to flush config files.", e); } } public void flushConfigFiles(final Runnable callback) { final FessConfig fessConfig = ComponentUtil.getFessConfig(); final String fesenType = fessConfig.getFesenType(); switch (fesenType) { case Constants.FESEN_TYPE_CLOUD:
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
final CountDownLatch gettersComplete = new CountDownLatch(nThreads); for (int i = 0; i < nThreads; i++) { final int index = i; Thread thread = new Thread( new Runnable() { @Override public void run() { gettersStartedSignal.countDown(); Object value = null; try {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
} @Override void maybeClearReferenceQueues() { clearReferenceQueue(queueForKeys); } } static final class CleanupMapTask implements Runnable { final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference; public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) { this.mapReference = new WeakReference<>(map); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
final CountDownLatch gettersComplete = new CountDownLatch(nThreads); for (int i = 0; i < nThreads; i++) { final int index = i; Thread thread = new Thread( new Runnable() { @Override public void run() { gettersStartedSignal.countDown(); Object value = null; try {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
logger.FatalIf(getMetacacheListingRPC.Register(gm, server.GetMetacacheListingHandler), "unable to register handler") logger.FatalIf(getMetricsRPC.Register(gm, server.GetMetricsHandler), "unable to register handler") logger.FatalIf(getNetInfoRPC.Register(gm, server.GetNetInfoHandler), "unable to register handler") logger.FatalIf(getOSInfoRPC.Register(gm, server.GetOSInfoHandler), "unable to register handler")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/xl-storage_test.go
t.Fatalf("Unable to create a file \"as-directory/as-file\", %s", err) } if err = xlStorage.AppendFile(context.Background(), "exists", "as-file/xl.meta", xlMeta); err != nil { t.Fatalf("Unable to create a file \"as-file\", %s", err) } if err = xlStorage.AppendFile(context.Background(), "exists", "as-file-parent/xl.meta", xlMeta); err != nil { t.Fatalf("Unable to create a file \"as-file-parent\", %s", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0)