Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 139 for Synchronizer (0.18 sec)

  1. platforms/core-runtime/build-process-services/src/main/java/org/gradle/internal/installation/CurrentGradleInstallationLocator.java

        private static final String BEACON_CLASS_NAME = "org.gradle.internal.installation.beacon.InstallationBeacon";
    
        private CurrentGradleInstallationLocator() {
        }
    
        public synchronized static CurrentGradleInstallation locate() {
            return locateViaClassLoader(CurrentGradleInstallationLocator.class.getClassLoader());
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 24 06:16:07 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/BootstrapSecurityManager.java

            this(null);
        }
    
        BootstrapSecurityManager(URLClassLoader target) {
            this.target = target;
        }
    
        @Override
        public void checkPermission(Permission permission) {
            synchronized (this) {
                if (initialised) {
                    return;
                }
                if (System.in == null) {
                    // Still starting up
                    return;
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 05:58:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy

            void queueIncoming(Message message) {
                synchronized (lock) {
                    receiveQueue << message
                    lock.notifyAll()
                }
            }
    
            void queueBroken(Throwable failure = new RuntimeException()) {
                queueIncoming(new Failure(failure))
            }
    
            Message receive() {
                synchronized (lock) {
                    while (receiveQueue.empty) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 19:51:37 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ThrottlingOutputEventListener.java

                    }
                }
            }, throttleMs, throttleMs, TimeUnit.MILLISECONDS);
        }
    
        @Override
        public void onOutput(OutputEvent newEvent) {
            synchronized (lock) {
                queue.add(newEvent);
    
                if (queue.size() == 10000) {
                    renderNow();
                    return;
                }
    
                if (newEvent instanceof InteractiveEvent) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. src/sync/once.go

    import (
    	"sync/atomic"
    )
    
    // Once is an object that will perform exactly one action.
    //
    // A Once must not be copied after first use.
    //
    // In the terminology of [the Go memory model],
    // the return from f “synchronizes before”
    // the return from any call of once.Do(f).
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type Once struct {
    	// done indicates whether the action has been performed.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. subprojects/core/src/integTest/groovy/org/gradle/cache/internal/DefaultGeneratedGradleJarCacheIntegrationTest.groovy

                            Thread.sleep(JAR_GENERATION_TIME_MS)
                            touch(file)
                        }
                    })
    
                    synchronized(jarFiles) {
                        jarFiles << jarFile
                    }
                }
            }
    
            concurrent.finished()
    
            then:
            triggeredJarFileGeneration.get() == 1
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. src/sync/mutex.go

    //
    // In the terminology of [the Go memory model],
    // the n'th call to [Mutex.Unlock] “synchronizes before” the m'th call to [Mutex.Lock]
    // for any n < m.
    // A successful call to [Mutex.TryLock] is equivalent to a call to Lock.
    // A failed call to TryLock does not establish any “synchronizes before”
    // relation at all.
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type Mutex struct {
    	state int32
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Sets.java

       *
       * @param navigableSet the navigable set to be "wrapped" in a synchronized navigable set.
       * @return a synchronized view of the specified navigable set.
       * @since 13.0
       */
      @GwtIncompatible // NavigableSet
      public static <E extends @Nullable Object> NavigableSet<E> synchronizedNavigableSet(
          NavigableSet<E> navigableSet) {
        return Synchronized.navigableSet(navigableSet);
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 77.3K bytes
    - Viewed (0)
  9. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformReplacer.java

                this.originalPath = originalPath;
                this.transformedJarPath = transformedJarPath;
            }
    
            @Override
            @Nullable
            public synchronized byte[] loadTransformedClass(String className) throws IOException {
                JarFile jarFile = getJarFileLocked();
                // From this point it is safe to load the bytes even if somebody attempts to close the replacer.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. subprojects/core/src/main/java/org/gradle/internal/service/scopes/SettingsScopeServices.java

            CacheConfigurationsInternal cacheConfigurations = objectFactory.newInstance(DefaultCacheConfigurations.class, legacyCacheCleanupEnablement);
            if (gradleInternal.isRootBuild()) {
                cacheConfigurations.synchronize(persistentCacheConfigurations);
                persistentCacheConfigurations.setCleanupHasBeenConfigured(false);
            }
            return cacheConfigurations;
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 09:21:42 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top