- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 115 for executorService (0.2 sec)
-
src/main/java/org/codelibs/core/timer/TimeoutManager.java
try { executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally { executorService.shutdownNow(); } } }
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
* test the forwarded methods */ } @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock. public void testListeningDecorator_noWrapExecuteTask() { ExecutorService delegate = mock(ExecutorService.class); ListeningExecutorService service = listeningDecorator(delegate); Runnable task = new Runnable() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
import java.util.concurrent.Delayed; import java.util.concurrent.ExecutorService; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy; import java.util.concurrent.TimeUnit; /** * Factory methods for {@link ExecutorService} for testing. * * @author Chris Nokleberg * @since 14.0 */ @GwtIncompatible
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
* test the forwarded methods */ } @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock. public void testListeningDecorator_noWrapExecuteTask() { ExecutorService delegate = mock(ExecutorService.class); ListeningExecutorService service = listeningDecorator(delegate); Runnable task = new Runnable() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
int count = 1; final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads); try { while (count != 0) { count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup); totalCount += count; } executorService.shutdown(); executorService.awaitTermination(60, TimeUnit.SECONDS);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
@JvmName("-deprecated_executorService") @Deprecated( message = "moved to val", replaceWith = ReplaceWith(expression = "executorService"), level = DeprecationLevel.ERROR, ) fun executorService(): ExecutorService = executorService
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public abstract class ForwardingExecutorService extends ForwardingObject implements ExecutorService { /** Constructor for use by subclasses. */ protected ForwardingExecutorService() {} @Override protected abstract ExecutorService delegate(); @CheckReturnValue @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
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/ListeningScheduledExecutorServiceTest.java
private long recordedInterval; private TimeUnit recordedTimeUnit; private final ListeningScheduledExecutorService executorService = new FakeExecutorService(); public void testScheduleRunnable() throws Exception { Runnable command = () -> {}; ListenableScheduledFuture<?> future = executorService.schedule(command, Duration.ofSeconds(12)); assertThat(future.get()).isEqualTo("schedule");
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/util/concurrent/MoreExecutors.java
* ExecutorService#shutdownNow()} and returns. * * @param service the {@code ExecutorService} to shut down * @param timeout the maximum time to wait for the {@code ExecutorService} to terminate * @param unit the time unit of the timeout argument * @return {@code true} if the {@code ExecutorService} was terminated successfully, {@code false}
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) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
} @AfterEach fun checkForPinning() { assertThat(capturedOut.toString()).isEmpty() } private fun newVirtualThreadPerTaskExecutor(): ExecutorService { return Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService } @Test fun testHttpsRequest() { MockServerClient(mockServer.host, mockServer.serverPort).use { mockServerClient -> mockServerClient
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 11:15:46 GMT 2024 - 3.7K bytes - Viewed (0)