- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 44 for Synchronizer (0.2 sec)
-
src/sync/pool.go
// free list. // // A Pool must not be copied after first use. // // In the terminology of [the Go memory model], a call to Put(x) “synchronizes before” // a call to [Pool.Get] returning that same value x. // Similarly, a call to New returning x “synchronizes before” // a call to Get returning that same value x. // // [the Go memory model]: https://go.dev/ref/mem type Pool struct { noCopy noCopy
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (0) -
platforms/core-configuration/flow-services/src/main/kotlin/org/gradle/internal/flow/services/BuildFlowScope.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 5.5K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/exception/DefaultExceptionHandlerTest.java
AtomicReference<Throwable> causeRef = new AtomicReference<>(null); Exception cause2 = new RuntimeException("loop") { @Override public synchronized Throwable getCause() { return causeRef.get(); } }; causeRef.set(cause2); Plugin plugin = new Plugin();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 10:31:03 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
maybeClosed(); } private void maybeClosed() { // This can be invoked from the reader thread or some other thread that is attempting to shut the client down. synchronized (lock) { if (!closed) { CloseInput message = new CloseInput(); dispatch.dispatch(message); closed = true; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/VisitableURLClassLoader.java
* * @param consumerId the consumer * @param onMiss called to create the initial data, when not found * @param <T> the type of data * @return user data */ public synchronized <T> T getUserData(Object consumerId, Factory<T> onMiss) { if (userData.containsKey(consumerId)) { return Cast.uncheckedCast(userData.get(consumerId)); } T value = onMiss.create();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 6.5K bytes - Viewed (0) -
src/sync/cond.go
// 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 // a call to [Cond.Broadcast] or [Cond.Signal] “synchronizes before” any Wait call // that it unblocks. // // For many simple use cases, users will be better off using channels than a // Cond (Broadcast corresponds to closing a channel, and Signal corresponds to
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/os/exec_windows.go
syscall.CloseHandle(syscall.Handle(p.handle)) } func findProcess(pid int) (p *Process, err error) { const da = syscall.STANDARD_RIGHTS_READ | syscall.PROCESS_QUERY_INFORMATION | syscall.SYNCHRONIZE h, e := syscall.OpenProcess(da, false, uint32(pid)) if e != nil { return nil, NewSyscallError("OpenProcess", e) } return newHandleProcess(pid, uintptr(h)), nil } func init() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 5K bytes - Viewed (0) -
internal/cachevalue/cache.go
// If NoWait is set, Get() will return the last good value, // if TTL has expired but 2x TTL has not yet passed, // but will fetch a new value in the background. NoWait bool } // Cache contains a synchronized value that is considered valid // for a specific amount of time. // An Update function must be set to provide an updated value when needed. type Cache[T any] struct { // updateFn must return an updated value.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/oldresult/TransientConfigurationResultsBuilder.java
encoder.writeSmallInt(artifactId); }); } public TransientConfigurationResults load(final ResolvedGraphResults graphResults, final SelectedArtifactResults artifactResults) { synchronized (lock) { return cache.load(() -> { try { return binaryData.read(decoder -> deserialize(decoder, graphResults, artifactResults, buildOperationProcessor));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 9.3K bytes - Viewed (0)