- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 269 for executors (0.13 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * @param executor The executor to decorate * @param nameSupplier The source of names for each task */ @J2ktIncompatible @GwtIncompatible // concurrency static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { checkNotNull(executor); checkNotNull(nameSupplier); return new Executor() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * @param executor The executor to decorate * @param nameSupplier The source of names for each task */ @J2ktIncompatible @GwtIncompatible // concurrency static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { checkNotNull(executor); checkNotNull(nameSupplier); return new Executor() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} public void testCompletionFinishesWithDone() { ExecutorService executor = Executors.newFixedThreadPool(10); for (int i = 0; i < 50000; i++) { final AbstractFuture<String> future = new AbstractFuture<String>() {}; final AtomicReference<String> errorMessage = Atomics.newReference(); executor.execute( new Runnable() { @Override public void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheUnsupportedTypesIntegrationTest.groovy
DefaultThreadFactory | ThreadFactory | "java.util.concurrent.Executors.defaultThreadFactory()" executorServiceTypeOnCurrentJvm() | Executor | "java.util.concurrent.Executors.newSingleThreadExecutor().tap { shutdown() }"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 28.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} public void testCompletionFinishesWithDone() { ExecutorService executor = Executors.newFixedThreadPool(10); for (int i = 0; i < 50000; i++) { final AbstractFuture<String> future = new AbstractFuture<String>() {}; final AtomicReference<String> errorMessage = Atomics.newReference(); executor.execute( new Runnable() { @Override public void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/NoDaemonGradleExecuter.java
+ "The test is most likely not written in a way that it can run with the embedded executer."); } NativeServicesTestFixture.initialize(); DefaultExecHandleBuilder builder = new DefaultExecHandleBuilder(TestFiles.pathToFileResolver(), Executors.newCachedThreadPool()) { @Override public File getWorkingDir() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 05:38:50 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
def build1 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() def build2 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() def build3 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() poll(120) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} } val logger = Logger.getLogger("TaskFaker." + instance++) /** Though this executor service may hold many threads, they are not executed concurrently. */ private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker")) /** * True if this task faker has ever had multiple tasks scheduled to run concurrently. Guarded by
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000)); executor.shutdown(); assertTrue(awaitTerminationUninterruptibly(executor, LONG_DELAY_MS, MILLISECONDS)); assertTrue(executor.isTerminated()); assertInterrupted(); } public void testTryAwaitTerminationUninterruptiblyLongTimeUnit_failure() { ExecutorService executor = newFixedThreadPool(1);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
import java.time.Duration; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.logging.ConsoleHandler; import java.util.logging.Level;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0)