- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for SynchronizedSet (0.55 sec)
-
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
ESSourceReader reader = new ESSourceReader(client, settings, indexName); reader.setScrollSize(1000); int count = 0; Set<String> valueSet = Collections.synchronizedSet(new HashSet<>()); Map<String, Object> source; while ((source = reader.read()) != null) { assertTrue(source.get("field1").toString().startsWith("test"));
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 8.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DependencyContext.java
scopesToCollectForCurrentProject = scopesToCollect; scopesToResolveForCurrentProject = scopesToResolve; scopesToCollectForAggregatedProjects = Collections.synchronizedSet(new TreeSet<>()); scopesToResolveForAggregatedProjects = Collections.synchronizedSet(new TreeSet<>()); } public MavenProject getProject() { return project; } public Collection<String> getScopesToCollectForCurrentProject() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jan 10 12:55:54 UTC 2024 - 3.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/ReactorBuildStatus.java
* * @since 3.0 */ public class ReactorBuildStatus { private final ProjectDependencyGraph projectDependencyGraph; private final Collection<String> blackListedProjects = Collections.synchronizedSet(new HashSet<>()); private volatile boolean halted = false; public ReactorBuildStatus(ProjectDependencyGraph projectDependencyGraph) { this.projectDependencyGraph = projectDependencyGraph; }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.3K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
/** * Fetches HTML from a requested URL, follows the links, and repeats. */ public final class Crawler { private final OkHttpClient client; private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>()); private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>(); private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>();
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 4.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Synchronized.java
@VisibleForTesting static <E extends @Nullable Object> Set<E> set(Set<E> set, @CheckForNull Object mutex) { return new SynchronizedSet<>(set, mutex); } static class SynchronizedSet<E extends @Nullable Object> extends SynchronizedCollection<E> implements Set<E> { SynchronizedSet(Set<E> delegate, @CheckForNull Object mutex) { super(delegate, mutex); } @Override Set<E> delegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 53.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/Synchronized.java
@VisibleForTesting static <E extends @Nullable Object> Set<E> set(Set<E> set, @CheckForNull Object mutex) { return new SynchronizedSet<>(set, mutex); } static class SynchronizedSet<E extends @Nullable Object> extends SynchronizedCollection<E> implements Set<E> { SynchronizedSet(Set<E> delegate, @CheckForNull Object mutex) { super(delegate, mutex); } @Override Set<E> delegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 57.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxer.java
private final PrintStream defaultPrintStream = new PrintStream(defaultOutputStreamForUnknownData); private final Set<ProjectSegment> completedBuilds = Collections.synchronizedSet(new HashSet<>()); private volatile ProjectSegment currentBuild; private final PrintStream originalSystemOUtStream; private final ConsolePrinter printer; /**
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 12.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
numSuccessfulSetCalls.incrementAndGet(); } awaitUnchecked(barrier); return null; } }; final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable = new Runnable() { @Override public void run() { try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
numSuccessfulSetCalls.incrementAndGet(); } awaitUnchecked(barrier); return null; } }; final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable = new Runnable() { @Override public void run() { try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/BenchmarkHelpers.java
} }, SynchronizedSetImpl { @Override public <E extends Comparable<E>> Set<E> create(Collection<E> contents) { return Collections.synchronizedSet(new HashSet<E>(contents)); } }, ImmutableSetImpl { @Override public <E extends Comparable<E>> Set<E> create(Collection<E> contents) { return ImmutableSet.copyOf(contents); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Mar 04 04:06:35 UTC 2022 - 12.3K bytes - Viewed (0)