Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 378 for striped (0.12 sec)

  1. guava/src/com/google/common/util/concurrent/Striped.java

      }
    
      /**
       * Creates a {@code Striped<Lock>} with eagerly initialized, strongly referenced locks. Every lock
       * is reentrant.
       *
       * @param stripes the minimum number of stripes (locks) required
       * @return a new {@code Striped<Lock>}
       */
      public static Striped<Lock> lock(int stripes) {
        return custom(stripes, PaddedLock::new);
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 10 20:55:18 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Striped.java

      }
    
      /**
       * Creates a {@code Striped<Lock>} with eagerly initialized, strongly referenced locks. Every lock
       * is reentrant.
       *
       * @param stripes the minimum number of stripes (locks) required
       * @return a new {@code Striped<Lock>}
       */
      public static Striped<Lock> lock(int stripes) {
        return custom(stripes, PaddedLock::new);
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 10 20:55:18 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        for (Striped<?> striped : allImplementations()) {
          assertBasicInvariants(striped);
        }
      }
    
      private static void assertBasicInvariants(Striped<?> striped) {
        Set<Object> observed = Sets.newIdentityHashSet(); // for the sake of weakly referenced locks.
        // this gets the stripes with #getAt(index)
        for (int i = 0; i < striped.size(); i++) {
          Object object = striped.getAt(i);
          assertNotNull(object);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        for (Striped<?> striped : allImplementations()) {
          assertBasicInvariants(striped);
        }
      }
    
      private static void assertBasicInvariants(Striped<?> striped) {
        Set<Object> observed = Sets.newIdentityHashSet(); // for the sake of weakly referenced locks.
        // this gets the stripes with #getAt(index)
        for (int i = 0; i < striped.size(); i++) {
          Object object = striped.getAt(i);
          assertNotNull(object);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  5. 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)
  6. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/ProducerGuardTest.groovy

                            }
                        })
                    }
                }
            }
    
            then:
            calls.get() == 100
    
            where:
            guard << [ProducerGuard.serial(), ProducerGuard.striped(), ProducerGuard.adaptive()]
        }
    
        def "does not call factories with the same key concurrently"() {
            def concurrentCalls = new AtomicInteger()
    
            when:
            async {
                100.times {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/css/javadoc.css

    }
    table.striped {
        border-collapse: collapse;
        border: 1px solid var(--table-border-color);
    }
    table.striped > thead {
        background-color: var(--subnav-background-color);
    }
    table.striped > thead > tr > th, table.striped > thead > tr > td {
        border: 1px solid var(--table-border-color);
    }
    table.striped > tbody > tr:nth-child(even) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 14:25:49 UTC 2024
    - 50.5K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cache_test.go

    	for _, numKeys := range []int{1 << 8, 1 << 12, 1 << 16} {
    		b.Run(fmt.Sprintf("Simple/keys=%d", numKeys), func(b *testing.B) {
    			benchmarkCache(newSimpleCache(clock.RealClock{}), b, numKeys)
    		})
    		b.Run(fmt.Sprintf("Striped/keys=%d", numKeys), func(b *testing.B) {
    			benchmarkCache(newStripedCache(32, fnvHashFunc, func() cache { return newSimpleCache(clock.RealClock{}) }), b, numKeys)
    		})
    	}
    }
    
    func TestStripedCache(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 15 09:52:18 UTC 2021
    - 3.1K bytes
    - Viewed (0)
Back to top