Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for BlockTarget (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top