- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 558 for nThreads (0.16 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
* However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li> * <li>should allow stopping or requesting stopping from a different thread than receiving/dispatching</li> * <li>don't guarantee allowing multiple threads dispatching</li> * </ul> */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
/** * A specification that uses multiple test threads. Provides an {@link Executor} and {@link org.gradle.internal.concurrent.ExecutorFactory} implementation. * * <p>This class maintains a set of instants reached by the test. An instant records the point in time that a test thread reached a certain point of its execution.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/UnitOfWorkParticipant.java
* Called just after the cache is locked. Called before any work is performed by other threads. This method may access the cache files. * * @param currentCacheState the current cache state. */ void afterLockAcquire(FileLock.State currentCacheState); /** * Called when the cache is due to be unlocked. Call after other threads have completed work. This method may access the cache files. */ void finishWork();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* This is useful if the given service uses daemon threads, and we want to keep the JVM from * exiting immediately on shutdown, instead giving these daemon threads a chance to terminate * normally. * * @param service ExecutorService which uses daemon threads * @param terminationTimeout how long to wait for the executor to finish before terminating the * JVM
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/DefaultProjectStateRegistryTest.groovy
// both threads are accessing project instant.finished1 thread.blockUntil.mutating2 // both threads are accessing project instant.finished2 } } } then: noExceptionThrown() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 24.6K bytes - Viewed (0) -
src/runtime/debug/garbage.go
// or are locked to other goroutines due to use of runtime.LockOSThread. // // SetMaxThreads is useful mainly for limiting the damage done by // programs that create an unbounded number of threads. The idea is // to take down the program before it takes down the operating system. func SetMaxThreads(threads int) int { return setMaxThreads(threads) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Callables.java
* @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once * for each invocation of the wrapped callable. */ @J2ktIncompatible @GwtIncompatible // threads static <T extends @Nullable Object> Callable<T> threadRenaming( Callable<T> callable, Supplier<String> nameSupplier) { checkNotNull(nameSupplier); checkNotNull(callable); return () -> {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
* @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once * for each invocation of the wrapped callable. */ @J2ktIncompatible @GwtIncompatible // threads static <T extends @Nullable Object> Callable<T> threadRenaming( Callable<T> callable, Supplier<String> nameSupplier) { checkNotNull(nameSupplier); checkNotNull(callable); return () -> {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
platforms/jvm/code-quality/src/main/groovy/org/gradle/api/plugins/quality/internal/PmdInvoker.groovy
} if (parameters.incrementalAnalysis.get()) { PmdInvoker.assertUnsupportedIncrementalAnalysis(version) } antPmdArgs['threads'] = parameters.threads.get() } else { // 6.+ if (parameters.incrementalAnalysis.get()) { antPmdArgs["cacheLocation"] = parameters.incrementalCacheFile.get().asFile
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 21 12:23:38 UTC 2023 - 7.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationExecutorParallelExecutionTest.groovy
20 | 4 } def "all work run to completion for multiple queues when using multiple threads #maxThreads"() { given: def amountOfWork = 10 setupBuildOperationExecutor(maxThreads) outerOperationCompletion.leaseFinish() // The work of this test is done by other threads def worker = new SimpleWorker() def numberOfQueues = 5 def operations = [
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.6K bytes - Viewed (0)