Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 122 for striped (0.13 sec)

  1. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java

                        producing.notifyAll();
                    }
                }
            }
        }
    
        private static class StripedProducerGuard<T> extends ProducerGuard<T> {
            private final Striped<Lock> locks = Striped.lock(Runtime.getRuntime().availableProcessors() * 4);
    
            @Override
            public <V> V guardByKey(T key, Supplier<V> supplier) {
                Lock lock = locks.get(key);
                lock.lock();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 16:02:31 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. platforms/core-execution/snapshots/src/main/java/org/gradle/internal/vfs/impl/DefaultFileSystemAccess.java

                virtualFileSystem.invalidateAll();
            }
        }
    
        private static class StripedProducerGuard<T> {
            private final Striped<Lock> locks = Striped.lock(Runtime.getRuntime().availableProcessors() * 4);
    
            public <V> V guardByKey(T key, Supplier<V> supplier) {
                Lock lock = locks.get(key);
                lock.lock();
                try {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 26 16:02:35 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. maven-embedder/src/test/java/org/apache/maven/cli/CLIManagerDocumentationTest.java

            }
        }
    
        String getOptionsAsHtml() {
            StringBuilder sb = new StringBuilder(512);
            boolean odd = true;
            sb.append(
                    "<table border='1' class='zebra-striped'><tr class='a'><th><b>Options</b></th><th><b>Description</b></th></tr>");
            for (Option option : new CLIManagerExtension().getOptions()) {
                odd = !odd;
                sb.append("<tr class='");
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Tue Jun 11 09:06:12 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/Striped64.java

     * Expert Group and released to the public domain, as explained at
     * http://creativecommons.org/publicdomain/zero/1.0/
     */
    
    /*
     * Source:
     * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/Striped64.java?revision=1.9
     */
    
    package com.google.common.hash;
    
    import com.google.common.annotations.GwtIncompatible;
    import java.util.Random;
    import javax.annotation.CheckForNull;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/Striped64.java

     * Expert Group and released to the public domain, as explained at
     * http://creativecommons.org/publicdomain/zero/1.0/
     */
    
    /*
     * Source:
     * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/Striped64.java?revision=1.9
     */
    
    package com.google.common.hash;
    
    import com.google.common.annotations.GwtIncompatible;
    import java.util.Random;
    import javax.annotation.CheckForNull;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Striped64.java

     * Expert Group and released to the public domain, as explained at
     * http://creativecommons.org/publicdomain/zero/1.0/
     */
    
    /*
     * Source:
     * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/Striped64.java?revision=1.9
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtIncompatible;
    import java.util.Random;
    import javax.annotation.CheckForNull;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/Striped64.java

     * Expert Group and released to the public domain, as explained at
     * http://creativecommons.org/publicdomain/zero/1.0/
     */
    
    /*
     * Source:
     * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/Striped64.java?revision=1.9
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtIncompatible;
    import java.util.Random;
    import javax.annotation.CheckForNull;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. docs/en/docs/advanced/behind-a-proxy.md

    ## About proxies with a stripped path prefix
    
    Keep in mind that a proxy with stripped path prefix is only one of the ways to configure it.
    
    Probably in many cases the default will be that the proxy doesn't have a stripped path prefix.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu May 02 22:37:31 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  9. platforms/ide/problems-api/build.gradle.kts

    }
    
    description = """A problems description API
        |
        |This project provides base classes to describe problems and their
        |solutions, in a way that enforces the creation of good error messages.
        |
        |It's a stripped down version of the original code available
        |at https://github.com/melix/jdoctor/
    """.trimMargin()
    
    gradlebuildJava.usedInWorkers()
    
    dependencies {
        api(projects.stdlibJavaExtensions)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 10 14:28:48 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/watch/watch.go

    	f.Lock()
    	defer f.Unlock()
    	if !f.stopped {
    		klog.V(4).Infof("Stopping fake watcher.")
    		close(f.result)
    		f.stopped = true
    	}
    }
    
    func (f *FakeWatcher) IsStopped() bool {
    	f.Lock()
    	defer f.Unlock()
    	return f.stopped
    }
    
    // Reset prepares the watcher to be reused.
    func (f *FakeWatcher) Reset() {
    	f.Lock()
    	defer f.Unlock()
    	f.stopped = false
    	f.result = make(chan Event)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:06:22 UTC 2024
    - 8.1K bytes
    - Viewed (1)
Back to top