- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for BlockTarget (0.15 sec)
-
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/BlockTarget.groovy
/** * A target for blocking. Exposes each named instant as a property, and accessing that property will block until the * instant has been reached. */ class BlockTarget { private final Instants instants BlockTarget(Instants instants) { this.instants = instants } def getProperty(String name) { instants.waitFor(name) true }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestThread.groovy
private final Instants instants TestThread(Instants instants) { this.instants = instants } void block() { Thread.sleep(750) } BlockTarget getBlockUntil() { return new BlockTarget(instants) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 971 bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpec.groovy
/** * An object that allows control over the current thread. */ final TestThread thread = new TestThread(instant) final BlockTarget waitFor = new BlockTarget(instant) public final TestExecutor executor = new TestExecutor(logger) public final TestExecutorFactory executorFactory = new TestExecutorFactory(executor) def setup() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccess.java
public FixedSharedModeCrossProcessCacheAccess(String cacheDisplayName, File lockTarget, LockOptions lockOptions, FileLockManager lockManager, CacheInitializationAction initializationAction, Consumer<FileLock> onOpenAction, Consumer<FileLock> onCloseAction) { assert lockOptions.getMode() == Shared; this.cacheDisplayName = cacheDisplayName; this.lockTarget = lockTarget; this.lockOptions = lockOptions;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedExclusiveModeCrossProcessCacheAccess.java
this.lockTarget = lockTarget; this.lockOptions = lockOptions; this.lockManager = lockManager; } @Override public void open() { if (fileLock != null) { throw new IllegalStateException("File lock " + lockTarget + " is already open."); } final FileLock fileLock = lockManager.lock(lockTarget, lockOptions, cacheDisplayName, "", unused -> {});
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 12:21:15 UTC 2024 - 3.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccess.java
*/ public LockOnDemandCrossProcessCacheAccess(String cacheDisplayName, File lockTarget, LockOptions lockOptions, FileLockManager lockManager, Lock stateLock, CacheInitializationAction initAction, Consumer<FileLock> onOpen, Consumer<FileLock> onClose) { this.cacheDisplayName = cacheDisplayName; this.lockTarget = lockTarget; this.lockOptions = lockOptions; this.lockManager = lockManager;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 6.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheCoordinator.java
fileAccess = new UnitOfWorkFileAccess(); break; case Exclusive:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 12:21:15 UTC 2024 - 20.5K bytes - Viewed (0)