- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 378 for striped (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)