- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 231 for synchronised (0.25 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/ExclusiveCacheAccessCoordinator.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.cache; import java.util.function.Supplier; /** * Provides synchronised access to a cache. */ public interface ExclusiveCacheAccessCoordinator { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/Synchronizer.java
// TODO Replace the use of this with synchronized caches from Guava @NonNullApi public class Synchronizer { private final Lock lock = new ReentrantLock(); public <T> T synchronize(Supplier<T> factory) { lock.lock(); try { return factory.get(); } finally { lock.unlock(); } } public void synchronize(Runnable operation) { lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/CacheAccessSerializer.java
final private Synchronizer synchronizer = new Synchronizer(); final private Cache<K, V> cache; public CacheAccessSerializer(Cache<K, V> cache) { this.cache = cache; } @Override public V get(final K key, final Function<? super K, ? extends V> factory) { return synchronizer.synchronize(() -> cache.get(key, factory)); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
src/sync/waitgroup.go
if race.Enabled { if delta < 0 { // Synchronize decrements with Wait. race.ReleaseMerge(unsafe.Pointer(wg)) } race.Disable() defer race.Enable() } state := wg.state.Add(uint64(delta) << 32) v := int32(state >> 32) w := uint32(state) if race.Enabled && delta > 0 && v == int32(delta) { // The first increment must be synchronized with Wait. // Need to model this as a read, because there can be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ScopedFingerprintWriter.kt
) : Closeable { override fun close() { // we synchronize access to all resources used by callbacks // in case there was still an event being dispatched at closing time. synchronized(writeContext) { unsafeWrite(null) writeContext.close() } } fun write(value: T, trace: PropertyTrace? = null) { synchronized(writeContext) { withPropertyTrace(trace) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 1.9K bytes - Viewed (0) -
src/runtime/proflabel.go
// the acquire in profBuf.read synchronizes with *all* prior // setProfLabel operations, not just the most recent one. This // is important because profBuf.read will observe different // labels set by different setProfLabel operations on // different goroutines, so it needs to synchronize with all // of them (this wouldn't be an issue if we could synchronize // on &getg().labels since we would synchronize with each
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:31 UTC 2024 - 4.7K bytes - Viewed (0) -
src/sync/rwmutex.go
// // In the terminology of [the Go memory model], // the n'th call to [RWMutex.Unlock] “synchronizes before” the m'th call to Lock // for any n < m, just as for [Mutex]. // For any call to RLock, there exists an n such that // the n'th call to Unlock “synchronizes before” that call to RLock, // and the corresponding call to [RWMutex.RUnlock] “synchronizes before” // the n+1'th call to Lock. // // [the Go memory model]: https://go.dev/ref/mem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LinePerThreadBufferingOutputStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0)