Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 806 for executors (0.24 sec)

  1. 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)
  2. 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)
  3. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleContextualExecuter.java

        public static boolean isConfigCache() {
            Executer executer = getSystemPropertyExecuter();
            return executer == Executer.configCache || executer == Executer.isolatedProjects;
        }
    
        public static boolean isNotIsolatedProjects() {
            return !isIsolatedProjects();
        }
    
        public static boolean isIsolatedProjects() {
            return getSystemPropertyExecuter() == Executer.isolatedProjects;
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 18:06:31 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

                      + runnable
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      private static final class RunnableExecutorPair {
        final Runnable runnable;
        final Executor executor;
        @CheckForNull RunnableExecutorPair next;
    
        RunnableExecutorPair(
            Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java

        }
    
        // public void test_doGet_mt() throws Exception {
        // ExecutorService executorService = Executors.newFixedThreadPool(1);
        //
        // // HttpClient Parameters
        // Map<String, Object> paramMap = new HashMap<String, Object>();
        // httpClient.setInitParameterMap(paramMap);
        //
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu May 09 09:28:25 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ExecutionList.java

                      + runnable
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      private static final class RunnableExecutorPair {
        final Runnable runnable;
        final Executor executor;
        @CheckForNull RunnableExecutorPair next;
    
        RunnableExecutorPair(
            Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. 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)
  10. subprojects/core/src/integTest/groovy/org/gradle/api/internal/tasks/TaskCacheabilityReasonIntegrationTest.groovy

            // Use max-workers=1 to force non-parallel execution and the tasks to run in the specified order
            // (--no-parallel doesn't have an effect with CC, but max-workers should affect both CC and parallel executors)
            args("--max-workers=1")
            return super.withBuildCache()
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 16:59:01 UTC 2024
    - 17.6K bytes
    - Viewed (0)
Back to top