- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 470 for executors (0.33 seconds)
-
.teamcity/scripts/CheckWrapper.java
* java .teamcity/scripts/CheckWrapper.java < commits.txt * * Reads commit SHAs from stdin (one per line), checks wrapper per commit. */ public class CheckWrapper { private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool(); private static final Pattern ALLOWED_WRAPPER_VERSION = Pattern.compile("^[0-9.]+(-(rc|milestone|m)-[0-9]+)?$"); // Keep the same extraction semantics as the old sed:
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 6.4K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
* limitations under the License. */ package com.google.common.util.concurrent.testing; import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService; import static java.util.concurrent.Executors.callable; import com.google.common.annotations.GwtIncompatible; import com.google.common.base.Preconditions; import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
* limitations under the License. */ package com.google.common.util.concurrent.testing; import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService; import static java.util.concurrent.Executors.callable; import com.google.common.annotations.GwtIncompatible; import com.google.common.base.Preconditions; import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertEquals(Service.State.STOPPING, state()); shutdownCalled++; } @Override protected Executor executor() { return executor; } @Override public void tearDown() throws Exception { executor.shutdown(); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 12.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.defaultThreadFactory; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.8K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
*/ package com.google.common.testing; import static com.google.common.testing.ReflectionFreeAssertThrows.assertThrows; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.newFixedThreadPool; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 6.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.Executors.defaultThreadFactory; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.8K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
break; default: List<MojoExecution> executions = step.executions().toList(); if (!executions.isEmpty()) { attachToThread(step); clock.start(); try { executions.forEach(mojoExecution -> {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 55.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newFixedThreadPool; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.collect.ConcurrentHashMultiset;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newFixedThreadPool; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.collect.ConcurrentHashMultiset;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 8.4K bytes - Click Count (0)