Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 173 for stoppable (0.16 sec)

  1. platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/health/memory/DefaultMemoryManager.java

    import com.google.common.annotations.VisibleForTesting;
    import com.google.common.base.Preconditions;
    import org.gradle.internal.concurrent.ExecutorFactory;
    import org.gradle.internal.concurrent.Stoppable;
    import org.gradle.internal.concurrent.ManagedScheduledExecutor;
    import org.gradle.internal.event.ListenerManager;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.util.ArrayList;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/api/internal/project/antbuilder/ClassPathToClassLoaderCache.java

    import org.gradle.internal.Factory;
    import org.gradle.internal.UncheckedException;
    import org.gradle.internal.classpath.ClassPath;
    import org.gradle.internal.concurrent.Stoppable;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.util.HashSet;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 7K bytes
    - Viewed (0)
  3. platforms/core-runtime/build-state/src/main/java/org/gradle/internal/buildprocess/BuildProcessState.java

        public void close() {
            // Force the user home services to be stopped first, because the dependencies between the user home services and the global services are not preserved currently
            CompositeStoppable.stoppable(services.get(GradleUserHomeScopeServiceRegistry.class), services).stop();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutor.java

        }
    
        @Override
        public String getDisplayName() {
            return actionExecutor.getDisplayName();
        }
    
        @Override
        public void stop() {
            CompositeStoppable.stoppable(lifecycle, executor, actionExecutor).stop();
        }
    
        @Override
        public void disconnect() {
            lifecycle.requestStop();
            executor.requestStop();
            actionExecutor.disconnect();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:55 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java

    import org.gradle.api.Transformer;
    import org.gradle.api.logging.LogLevel;
    import org.gradle.api.logging.Logger;
    import org.gradle.api.logging.Logging;
    import org.gradle.internal.concurrent.Stoppable;
    import org.gradle.internal.event.ListenerManager;
    import org.gradle.internal.logging.LoggingManagerInternal;
    import org.gradle.internal.logging.events.LogLevelChangeEvent;
    import org.gradle.internal.logging.events.OutputEvent;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 30 19:54:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/ResourceCleaningCompilationTask.java

            delegate.setLocale(locale);
        }
    
        @Override
        public Boolean call() {
            try {
                return delegate.call();
            } finally {
                CompositeStoppable.stoppable(fileManager).stop();
                cleanupZipCache();
            }
        }
    
        /**
         * The javac file manager uses a shared ZIP cache which keeps file handles open
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Aug 28 11:40:18 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  7. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/ForegroundDaemonAction.java

                daemonRegistry.markState(daemon.getAddress(), Idle);
                daemon.stopOnExpiration(expirationStrategy, configuration.getPeriodicCheckIntervalMs());
            } finally {
                CompositeStoppable.stoppable(daemon, daemonProcessState).stop();
            }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/loader/SynchronizedToolingImplementationLoader.java

            } finally {
                lock.unlock();
                logger.completed();
            }
        }
    
        @Override
        public void close() {
            lock.lock();
            try {
                CompositeStoppable.stoppable(delegate).stop();
            } finally {
                lock.unlock();
            }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  9. platforms/core-runtime/build-state/src/main/java/org/gradle/internal/session/BuildSessionState.java

         */
        public <T> T run(Function<? super BuildSessionContext, T> action) {
            return action.apply(context);
        }
    
        @Override
        public void close() {
            CompositeStoppable.stoppable(sessionScopeServices, (Closeable) () -> userHomeScopeServiceRegistry.release(userHomeServices)).stop();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 13 21:54:27 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  10. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonTcpServerConnector.java

        @Override
        public void stop() {
            lifecycleLock.lock();
            try {
                stopped = true;
            } finally {
                lifecycleLock.unlock();
            }
    
            CompositeStoppable.stoppable(acceptor, incomingConnector).stop();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 4.1K bytes
    - Viewed (0)
Back to top