Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 577 for executors (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildParams.kt

    
    val Project.defaultPerformanceBaselines: Provider<String>
        get() = gradleProperty(DEFAULT_PERFORMANCE_BASELINES)
    
    
    // null means no limit: use all available executors
    val Project.maxTestDistributionRemoteExecutors: Int?
        get() = gradleProperty(MAX_TEST_DISTRIBUTION_REMOTE_EXECUTORS).orNull?.toInt()
    
    val Project.maxTestDistributionLocalExecutors: Int?
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 04 06:42:07 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

              fail();
            }
            throw new MyError();
          }
        };
      }
    
      // TODO(cpovirk): top-level class?
      static class ExecutorSpy implements Executor {
    
        Executor delegate;
        boolean wasExecuted;
    
        public ExecutorSpy(Executor delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void execute(Runnable command) {
          delegate.execute(command);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
Back to top