- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for ConcurrentHashMap (0.43 sec)
-
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultModelCache.java
ConcurrentHashMap<Object, Supplier<?>> cache; RepositoryCache repositoryCache = session != null ? session.getCache() : null; if (repositoryCache == null) { return new DefaultModelCache(new ConcurrentHashMap<>()); } else { if (anew) { cache = new ConcurrentHashMap<>(); repositoryCache.put(session, KEY, cache);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 6.8K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelTransformerContext.java
final ModelProcessor modelLocator; final Map<String, String> userProperties = new ConcurrentHashMap<>(); final Map<Path, Holder> modelByPath = new ConcurrentHashMap<>(); final Map<GAKey, Holder> modelByGA = new ConcurrentHashMap<>(); public static class Holder { private volatile boolean set; private volatile Model model; Holder() {}
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 4K 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) -
android/guava-tests/test/com/google/common/collect/MapMakerTest.java
import com.google.common.annotations.J2ktIncompatible; import com.google.common.base.Function; import com.google.common.testing.NullPointerTester; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import junit.framework.TestCase; /** * @author Charles Fry */ @GwtCompatible(emulated = true) @J2ktIncompatible // MapMaker
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 26 16:35:21 GMT 2024 - 2.6K 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) -
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) -
android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
* existing multiset values. * * @author mike nonemacher */ public class ConcurrentHashMultisetBasherTest extends TestCase { public void testAddAndRemove_ConcurrentHashMap() throws Exception { testAddAndRemove(new ConcurrentHashMap<String, AtomicInteger>()); } public void testAddAndRemove_ConcurrentSkipListMap() throws Exception { testAddAndRemove(new ConcurrentSkipListMap<String, AtomicInteger>()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/Maps.java
} /** * 指定されたキーと値を持つ{@link ConcurrentHashMap}を構築するための{@literal Maps}を返します。 * * @param <KEY> * <code>Map</code>のキーの型 * @param <VALUE> * <code>Map</code>の値ーの型 * @param key * <code>Map</code>に追加されるキー * @param value * <code>Map</code>に追加される値 * @return 指定されたキーと値を持つ{@link ConcurrentHashMap}を構築するための{@literal Maps} */
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K 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) -
maven-core/src/main/java/org/apache/maven/project/artifact/DefaultProjectArtifactsCache.java
&& aggregating == that.aggregating; } } protected final Map<Key, CacheRecord> cache = new ConcurrentHashMap<>(); protected final Map<Key, Key> keys = new ConcurrentHashMap<>(); @Override public Key createKey( MavenProject project, Collection<String> scopesToCollect,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 23:31:49 GMT 2024 - 8.3K bytes - Viewed (0)