- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for ConcurrentHashMap (0.26 sec)
-
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/Platform.java
// GWT's ConcurrentHashMap is a wrapper around HashMap, but it rejects null keys, which matches // the behaviour of the non-GWT implementation of newConcurrentHashSet(). // On the other hand HashSet might be better for code size if apps aren't // already using Collections.newSetFromMap and ConcurrentHashMap. return Collections.newSetFromMap(new ConcurrentHashMap<E, Boolean>()); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Jun 29 18:16:45 GMT 2023 - 4.7K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>()); private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>(); private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>(); public Crawler(OkHttpClient client) { this.client = client; } private void parallelDrainQueue(int threadCount) {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 4.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultArtifactManager.java
import javax.inject.Inject; import javax.inject.Named; import java.nio.file.Path; import java.util.Map; import java.util.Objects; import java.util.Optional; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Stream; import org.apache.maven.api.Artifact; import org.apache.maven.api.annotations.Nonnull; import org.apache.maven.api.di.SessionScoped;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 3.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/DefaultExtensionRealmCache.java
import javax.inject.Named; import javax.inject.Singleton; import java.io.File; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.concurrent.ConcurrentHashMap; import org.apache.maven.artifact.Artifact; import org.apache.maven.project.ExtensionDescriptor; import org.apache.maven.project.MavenProject; import org.codehaus.plexus.classworlds.realm.ClassRealm;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 4.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java
import javax.inject.Inject; import javax.inject.Named; import javax.inject.Singleton; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; import org.apache.maven.api.JavaPathType; import org.apache.maven.api.Type; import org.apache.maven.api.annotations.Nonnull;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 3.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
import org.codelibs.fess.util.JobProcess; public class ProcessHelper { private static final Logger logger = LogManager.getLogger(ProcessHelper.class); protected final ConcurrentHashMap<String, JobProcess> runningProcessMap = new ConcurrentHashMap<>(); protected int processDestroyTimeout = 10; @PreDestroy public void destroy() { for (final String sessionId : runningProcessMap.keySet()) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectRealmCache.java
import javax.inject.Named; import javax.inject.Singleton; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.concurrent.ConcurrentHashMap; import org.codehaus.plexus.classworlds.realm.ClassRealm; import org.codehaus.plexus.classworlds.realm.NoSuchRealmException; import org.codehaus.plexus.personality.plexus.lifecycle.phase.Disposable;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 3.7K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/collect/MapBenchmark.java
Map<Element, Element> map = new ConcurrentHashMap<>(keys.size(), 0.75f, 1); for (Element element : keys) { map.put(element, element); } return map; } }, ConcurrentHM16 { @Override Map<Element, Element> create(Collection<Element> keys) { Map<Element, Element> map = new ConcurrentHashMap<>(keys.size(), 0.75f, 16);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 7.6K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/MapMaker.java
*/ package com.google.common.collect; import static com.google.common.base.Preconditions.checkArgument; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; /** * MapMaker emulation. * * @author Charles Fry */ @ElementTypesAreNonnullByDefault public final class MapMaker { private int initialCapacity = 16;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ForwardingConcurrentMapTest.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.collect; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import junit.framework.TestCase; /** * Tests for {@link ForwardingConcurrentMap}. * * @author Jared Levy */
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.4K bytes - Viewed (0)