- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 362 for synchronised (0.21 sec)
-
subprojects/core/src/integTest/groovy/org/gradle/api/events/BuildExecutionEventsIntegrationTest.groovy
"gradle.taskGraph.afterTask" | "TaskExecutionGraph.afterTask" } @UnsupportedWithConfigurationCache(because = "tests listener behaviour") def "events passed to any task execution listener are synchronised"() { createDirs("a", "b", "c") settingsFile << "include 'a', 'b', 'c'" buildFile """ def listener = new MyListener() gradle.addListener(listener)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 4.7K bytes - Viewed (0) -
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-runtime/base-services/src/main/java/org/gradle/internal/work/Synchronizer.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.work; import org.gradle.internal.Factory; public interface Synchronizer { /** * Runs the given action while holding the associated resource lock, blocking until the lock can be acquired. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
protected abstract void doSend( Request request ) throws IOException; protected abstract void doRecv( Response response ) throws IOException; protected abstract void doSkip() throws IOException; public synchronized void sendrecv( Request request, Response response, long timeout ) throws IOException { makeKey( request ); response.isReceived = false; try {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K 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) -
testing/internal-testing/src/test/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpecTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultSynchronizer.java
if (!workerLeaseService.isWorkerThread()) { throw new IllegalStateException("The current thread is not registered as a worker thread."); } synchronized (this) { if (owner == null) { owner = currentThread; return null; } else if (owner == currentThread) { return currentThread; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.7K 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)