Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 470 for executors (0.33 seconds)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top