- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 3,449 for held (0.04 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseService.java
/** * Runs a given {@link Factory} while the specified locks are being held, releasing * the locks upon completion. Blocks until the specified locks can be obtained. */ <T> T withLocks(Collection<? extends ResourceLock> locks, Factory<T> factory); /** * Runs a given {@link Runnable} while the specified locks are being held, releasing
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go
// (to the degree allowed by the Go runtime scheduler), and increment the // goroutine counter before that. // The WriteOnce's Get method must be called without the lock held. // The WriteOnce's Set method must be called with the lock held. func NewCountingWriteOnce(activeCounter counter.GoRoutineCounter, lock sync.Locker, initial interface{}, doneCh <-chan struct{}, doneVal interface{}) promiseifc.WriteOnce { p := &countingPromise{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 3.3K bytes - Viewed (0) -
src/net/internal/socktest/switch_unix.go
sw.smu.RLock() defer sw.smu.RUnlock() so, ok := sw.sotab[s] if !ok { return nil } return &so } // addLocked returns a new Status without locking. // sw.smu must be held before call. func (sw *Switch) addLocked(s, family, sotype, proto int) *Status { sw.once.Do(sw.init) so := Status{Cookie: cookie(family, sotype, proto)} sw.sotab[s] = so return &so
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:54:10 UTC 2023 - 718 bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DaemonForkOptionsBuilder.java
} return new DaemonForkOptions(forkOptions, keepAliveMode, classLoaderStructure); } /** * Users can add files that are held open by the worker process. This causes problems on Windows with persistent workers because * we cannot delete files that are held by the worker process. * * @param jvmArgs JVM arguments to check
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 4.8K bytes - Viewed (0) -
src/crypto/tls/cache.go
// multiple Conns. Returned references should not be mutated by callers. Certificates // are still safe to use after they are removed from the cache. // // Certificates are returned wrapped in an activeCert struct that should be held by // the caller. When references to the activeCert are freed, the number of references // to the certificate in the cache is decremented. Once the number of references // reaches zero, the entry is evicted from the cache. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 23:56:41 UTC 2023 - 3.4K bytes - Viewed (0) -
src/sync/cond.go
// Cond implements a condition variable, a rendezvous point // for goroutines waiting for or announcing the occurrence // of an event. // // Each Cond has an associated Locker L (often a [*Mutex] or [*RWMutex]), // which must be held when changing the condition and // when calling the [Cond.Wait] method. // // A Cond must not be copied after first use. // // In the terminology of [the Go memory model], Cond arranges that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
src/net/internal/socktest/switch_windows.go
sw.smu.RLock() defer sw.smu.RUnlock() so, ok := sw.sotab[s] if !ok { return nil } return &so } // addLocked returns a new Status without locking. // sw.smu must be held before call. func (sw *Switch) addLocked(s syscall.Handle, family, sotype, proto int) *Status { sw.once.Do(sw.init) so := Status{Cookie: cookie(family, sotype, proto)} sw.sotab[s] = so return &so
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 13 21:38:34 UTC 2015 - 730 bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/CacheBuilder.java
* cross-process access. */ CacheBuilder withInitializer(Consumer<? super PersistentCache> initializer); /** * Specifies an action to execute when the cache needs to be cleaned up. An exclusive lock is held while the cleanup is executing, to prevent cross-process access. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/dependencysubstitution/DependencySubstitutionsInternal.java
void setMutationValidator(MutationValidator validator); DependencySubstitutionsInternal copy(); /** * Discard all state held by this container. */ void discard();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccess.java
import static org.gradle.cache.FileLockManager.LockMode.Shared; /** * A {@link CrossProcessCacheAccess} implementation used when a cache is opened with a shared lock that is held until the cache is closed. The contract for {@link CrossProcessCacheAccess} requires an * exclusive lock be held, so this implementation simply throws 'not supported' exceptions for these methods. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.7K bytes - Viewed (0)