- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 139 for Synchronizer (0.32 sec)
-
pkg/kubelet/eviction/eviction_manager_test.go
_, err = manager.synchronize(diskInfoProvider, activePodsFunc) if err != nil { t.Fatalf("Manager should not have an error %v", err) } // we should not have disk pressure if manager.IsUnderDiskPressure() { t.Fatalf("Manager should not report disk pressure") } // synchronize _, err = manager.synchronize(diskInfoProvider, activePodsFunc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheClassLoaderScopeRegistryListener.kt
override fun scopeFor(classLoader: ClassLoader?): Pair<ClassLoaderScopeSpec, ClassLoaderRole>? { synchronized(lock) { return loaders[classLoader] } } override fun childScopeCreated(parentId: ClassLoaderScopeId, childId: ClassLoaderScopeId, origin: ClassLoaderScopeOrigin?) { synchronized(lock) { if (scopeSpecs.containsKey(childId)) { // scope is being reused
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 4.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/services/internal/RegisteredBuildServiceProvider.java
synchronized (instanceLock) { stopActions = stopActions.plus(stopAction); } } @Override protected Value<? extends T> calculateOwnValue(ValueConsumer consumer) { return Value.of(getInstance()); } private T getInstance() { listener.beforeGet(this); synchronized (instanceLock) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 09:24:00 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/health/memory/DefaultMemoryManager.java
} } } @Override public void addMemoryHolder(MemoryHolder holder) { synchronized (holdersLock) { holders.add(holder); } } @Override public void removeMemoryHolder(MemoryHolder holder) { synchronized (holdersLock) { holders.remove(holder); } } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:38 UTC 2024 - 9K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/TestInMemoryCacheFactory.java
synchronized (this) { return action.get(); } } @Override public void useCache(Runnable action) { assertNotClosed(); // The contract of useCache() means we have to provide some basic synchronization. synchronized (this) { action.run(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 21:54:27 UTC 2024 - 6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/deprecation/DeprecationLogger.java
public synchronized static void init(WarningMode warningMode, BuildOperationProgressEventEmitter buildOperationProgressEventEmitter, Problems problemsService, ProblemStream problemStream) { DEPRECATED_FEATURE_HANDLER.init(warningMode, buildOperationProgressEventEmitter, problemsService, problemStream); } public synchronized static void reset() { DEPRECATED_FEATURE_HANDLER.reset();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 13.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/SystemProperties.java
* * @param propertyName The name of the property to set * @param value The value to temporarily set the property to * @param factory Instance created by the Factory implementation */ public synchronized <T> T withSystemProperty(String propertyName, String value, Factory<T> factory) { String originalValue = overrideProperty(propertyName, value); try { return factory.create();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
synchronized (state) { if (state.seenExceptions == expect) { state.seenExceptions = update; } } } @Override int decrementAndGetRemainingCount(AggregateFutureState<?> state) { synchronized (state) { return --state.remaining; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java
private final Map<TransferResourceIdentifier, TransferResourceAndSize> transfers = new LinkedHashMap<>(); private final FileSizeFormat format = new FileSizeFormat(); // use in a synchronized fashion private final StringBuilder buffer = new StringBuilder(128); // use in a synchronized fashion private final boolean printResourceNames; private int lastLength; public ConsoleMavenTransferListener(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 21:48:41 UTC 2024 - 5.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
* HashMultimap.<K, V>create()); * ... * Collection<V> values = multimap.get(key); // Needn't be in synchronized block * ... * synchronized (multimap) { // Synchronizing on multimap, not values! * Iterator<V> i = values.iterator(); // Must be in synchronized block * while (i.hasNext()) { * foo(i.next()); * } * } * }</pre> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 86.3K bytes - Viewed (0)