Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for createScheduled (0.28 sec)

  1. platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy

                thread.block()
                instant.completed2
            } as Callable<Void>
    
            when:
            async {
                factory.createScheduled("1", 1).schedule(action1, 0, TimeUnit.SECONDS)
                factory.createScheduled("2", 1).schedule(action2, 0, TimeUnit.SECONDS)
                thread.blockUntil.started1
                thread.blockUntil.started2
                instant.willStop
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestExecutorFactory.groovy

            throw new UnsupportedOperationException()
        }
    
        @Override
        ManagedScheduledExecutor createScheduled(String displayName, int fixedSize) {
            throw new UnsupportedOperationException()
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/health/DaemonHealthStats.java

        public DaemonHealthStats(DaemonRunningStats runningStats, GarbageCollectorMonitoringStrategy strategy, ExecutorFactory executorFactory) {
            this.runningStats = runningStats;
            this.scheduler = executorFactory.createScheduled("Daemon health stats", 1);
            this.gcInfo = new GarbageCollectionInfo();
            this.gcMonitor = new DefaultGarbageCollectionMonitor(strategy, scheduler);
        }
    
        @VisibleForTesting
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sun May 05 22:23:18 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorFactory.java

         * @param fixedSize The maximum number of threads allowed
         * @return The executor
         * @see java.util.concurrent.ScheduledExecutorService
         */
        ManagedScheduledExecutor createScheduled(String displayName, int fixedSize);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/DefaultExecutorFactory.java

            return Executors.newFixedThreadPool(fixedSize, newThreadFactory(displayName));
        }
    
        @Override
        public ManagedScheduledExecutor createScheduled(String displayName, int fixedSize) {
            ManagedScheduledExecutor executor = new TrackedScheduledManagedExecutor(createScheduledExecutor(displayName, fixedSize), new ExecutorPolicy.CatchAndRecordFailures());
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/health/memory/DefaultMemoryManager.java

            this.osMemoryInfo = osMemoryInfo;
            this.jvmMemoryInfo = jvmMemoryInfo;
            this.listenerManager = listenerManager;
            this.scheduler = executorFactory.createScheduled("Memory manager", 1);
            this.jvmBroadcast = listenerManager.getBroadcaster(JvmMemoryStatusListener.class);
            this.osBroadcast = listenerManager.getBroadcaster(OsMemoryStatusListener.class);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/internal/service/scopes/GradleUserHomeScopeServices.java

        }
    
        @Provides
        TimeoutHandler createTimeoutHandler(ExecutorFactory executorFactory, CurrentBuildOperationRef currentBuildOperationRef) {
            return new DefaultTimeoutHandler(executorFactory.createScheduled("execution timeouts", 1), currentBuildOperationRef);
        }
    
        @Provides
        LegacyCacheCleanupEnablement createLegacyCacheCleanupEnablement(GradleUserHomeDirProvider gradleUserHomeDirProvider) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java

            this.daemonContext = daemonContext;
            this.commandExecuter = commandExecuter;
            this.executorFactory = executorFactory;
            this.scheduledExecutorService = executorFactory.createScheduled("Daemon periodic checks", 1);
            this.listenerManager = listenerManager;
        }
    
        public String getUid() {
            return daemonContext.getUid();
        }
    
        public Address getAddress() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:38 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy

                    throw new UnsupportedOperationException()
                }
    
                @Override
                ManagedScheduledExecutor createScheduled(String displayName, int fixedSize) {
                    throw new UnsupportedOperationException()
                }
            }
        }
    
        Executor getExecutor() {
            return new Executor() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 22.9K bytes
    - Viewed (0)
Back to top