- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,570 for executors (0.3 sec)
-
maven-jline/src/main/java/org/apache/maven/jline/FastTerminal.java
final Future<Terminal> terminal; public FastTerminal(Callable<Terminal> builder, Consumer<Terminal> consumer) { ExecutorService executor = Executors.newSingleThreadExecutor(); terminal = executor.submit(() -> { try { Terminal terminal = builder.call(); consumer.accept(terminal); return terminal;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Apr 03 17:49:40 UTC 2024 - 6.7K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java
import java.io.PrintStream; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import org.apache.maven.jline.JLineMessageBuilderFactory; import org.eclipse.aether.DefaultRepositorySystemSession; import org.eclipse.aether.transfer.TransferCancelledException;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import junit.framework.TestCase; /** * Test case for {@link ListenableFutureTask}. * * @author Sven Mawson */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale; import java.util.concurrent.Executors; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicLong; import javax.annotation.CheckForNull; /** * A ThreadFactory builder, providing any combination of these features: *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 10 21:56:03 UTC 2023 - 7.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
import com.google.common.testing.TestLogHandler; import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; import junit.framework.TestCase; /** Tests for {@link ListenerCallQueue}. */ public class ListenerCallQueueTest extends TestCase {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
import com.google.common.testing.TestLogHandler; import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; import junit.framework.TestCase; /** Tests for {@link ListenerCallQueue}. */ public class ListenerCallQueueTest extends TestCase {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testRunIdempotency() throws Exception { final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); for (int i = 0; i < 1000; i++) { final AtomicInteger counter = new AtomicInteger(); final TrustedListenableFutureTask<Integer> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ProgressBar.java
import org.gradle.internal.nativeintegration.console.ConsoleMetaData; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class ProgressBar { private static final Logger LOGGER = LoggerFactory.getLogger(ProgressBar.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 5.7K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxerTest.java
"hand"); Iterator<String> lyrics = stringList.iterator(); ExecutorService executor = Executors.newFixedThreadPool(10); CompletionService<ProjectSegment> service = new ExecutorCompletionService<>(executor); List<Future<ProjectSegment>> futures = new ArrayList<>(); for (ProjectSegment projectBuild : projectBuildList) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 6.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
signaled.set(true) } then: poll { assert signaled.get() } } def "there are only two executors: one lock request listener and one release lock action executor"() { def factory = Mock(ExecutorFactory) handler = new DefaultFileLockContentionHandler(factory, addressProvider) when: handler.reservePort()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0)