- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 126 for acquirem (0.24 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockState.java
* notify threads waiting on a lock. */ void registerUnlocked(ResourceLock resourceLock); /** * Release any locks that have been acquired during the transform. */ void releaseLocks();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 1.3K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary-bare-m.go
testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) } func gen(t *testgen.Trace) { g := t.Generation(1) // One goroutine is exiting with a syscall. It already // acquired a new P. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall) b0.Event("GoSyscallEndBlocked")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 956 bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/CrossProcessCacheAccess.java
/** * Runs the given action while this process is holding an exclusive file lock on the cache. Multiple threads may run concurrently. */ <T> T withFileLock(Supplier<T> factory); /** * Acquires an exclusive file lock on the cache. The caller is responsible for running the resulting action to release the lock. * The lock may be released by any thread. */ Runnable acquireFileLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecution.java
*/ package org.gradle.internal.work; /** * Represents an execution. */ public interface ConditionalExecution<T> { /** * Provides the Runnable that should be executed once the resource lock is acquired. */ Runnable getExecution(); /** * Blocks waiting for this execution to complete. Returns a result provided by the execution. */ T await(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/UnknownModelException.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.tooling; /** * Thrown when the client is trying to acquire a model that is unknown to the Tooling API. * <p> * The exception extends {@link UnsupportedVersionException} only for backwards compatibility reasons. * * @since 1.0-milestone-8 */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary-reacquire-new-proc.go
testgen "internal/trace/internal/testgen/go122" ) func main() { testgen.Main(gen) } func gen(t *testgen.Trace) { g := t.Generation(1) // One goroutine is exiting with a syscall. It already // acquired a new P. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/AbstractTrackedResourceLock.java
} @Override public boolean tryLock() { if (!isLockedByCurrentThread()) { if (acquireLock()) { LOGGER.debug("{}: acquired lock on {}", Thread.currentThread().getName(), displayName); try { owner.lockAcquired(this); } catch (RuntimeException e) { releaseLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 3.2K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-create-syscall-with-p.go
) func main() { testgen.Main(gen) } func gen(t *testgen.Trace) { t.ExpectFailure(".*expected a proc but didn't have one.*") g := t.Generation(1) // A C thread calls into Go and acquires a P. It returns // back to C, destroying the G. It then comes back to Go // on the same thread and again returns to C. // // Note: on pthread platforms this can't happen on the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/equality.go
// slow path which checks the full object. oldAccessor, err := meta.Accessor(oldObj) if err != nil { return nil, fmt.Errorf("failed to acquire accessor for oldObj: %v", err) } accessor, err := meta.Accessor(newObj) if err != nil { return nil, fmt.Errorf("failed to acquire accessor for newObj: %v", err) } oldManagedFields := oldAccessor.GetManagedFields() newManagedFields := accessor.GetManagedFields()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 28 14:56:34 UTC 2022 - 5.3K bytes - Viewed (0) -
src/sync/pool.go
if race.Enabled { race.Enable() if x != nil { race.Acquire(poolRaceAddr(x)) } } if x == nil && p.New != nil { x = p.New() } return x } func (p *Pool) getSlow(pid int) any { // See the comment in pin regarding ordering of the loads. size := runtime_LoadAcquintptr(&p.localSize) // load-acquire locals := p.local // load-consume
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (1)