- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for AtomicLong (0.09 sec)
-
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
* zero values have been removed and others have not. */ public void removeAllZeros() { Iterator<Entry<K, AtomicLong>> entryIterator = map.entrySet().iterator(); while (entryIterator.hasNext()) { Entry<K, AtomicLong> entry = entryIterator.next(); AtomicLong atomic = entry.getValue(); if (atomic != null && atomic.get() == 0L) { entryIterator.remove(); } } }
Registered: 2024-11-01 12:43 - Last Modified: 2024-04-01 16:15 - 14.1K bytes - Viewed (0) -
guava/src/com/google/common/hash/LongAddables.java
* the License. */ package com.google.common.hash; import com.google.common.base.Supplier; import java.util.concurrent.atomic.AtomicLong; /** * Source of {@link LongAddable} objects that deals with GWT, Unsafe, and all that. * * @author Louis Wasserman */ @ElementTypesAreNonnullByDefault final class LongAddables {
Registered: 2024-11-01 12:43 - Last Modified: 2022-01-04 17:27 - 1.9K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
@Param("2.5") double concentration; Random random = new Random(); LoadingCache<Integer, Integer> cache; int max; static AtomicLong requests = new AtomicLong(0); static AtomicLong misses = new AtomicLong(0); @BeforeExperiment void setUp() { // random integers will be generated in this range, then raised to the // power of (1/concentration) and floor()ed
Registered: 2024-11-01 12:43 - Last Modified: 2017-12-04 17:37 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
public class IndexUpdateCallbackImpl implements IndexUpdateCallback { private static final Logger logger = LogManager.getLogger(IndexUpdateCallbackImpl.class); protected AtomicLong documentSize = new AtomicLong(0); protected volatile long executeTime = 0; protected final DocList docList = new DocList(); protected long maxDocumentRequestSize; protected int maxDocumentCacheSize;
Registered: 2024-10-31 13:40 - Last Modified: 2024-02-22 01:53 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeHandleImpl.java
private final SmbResourceLocatorImpl resourceLoc; private final SmbTreeConnection treeConnection; private final AtomicLong usageCount = new AtomicLong(1); /** * @param resourceLoc * @param treeConnection */ public SmbTreeHandleImpl ( SmbResourceLocatorImpl resourceLoc, SmbTreeConnection treeConnection ) {
Registered: 2024-11-03 00:10 - Last Modified: 2018-07-01 13:12 - 8.9K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
@Param("2.5") double concentration; Random random = new Random(); LoadingCache<Integer, Integer> cache; int max; static AtomicLong requests = new AtomicLong(0); static AtomicLong misses = new AtomicLong(0); @BeforeExperiment void setUp() { // random integers will be generated in this range, then raised to the // power of (1/concentration) and floor()ed
Registered: 2024-11-01 12:43 - Last Modified: 2017-12-04 17:37 - 3.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java
try { final URL u = new URL(url); final String host = u.getHost(); if (host == null) { return; } final AtomicLong lastTime = lastTimes.putIfAbsent(host, new AtomicLong(SystemUtil.currentTimeMillis())); if (lastTime == null) { return; } synchronized (lastTime) { while (true) {
Registered: 2024-11-10 03:50 - Last Modified: 2024-02-22 01:36 - 3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/FakeTicker.java
* <p>This class is thread-safe. * * @author Jige Yu * @since 10.0 */ @ElementTypesAreNonnullByDefault @GwtCompatible public class FakeTicker extends Ticker { private final AtomicLong nanos = new AtomicLong(); private volatile long autoIncrementStepNanos; /** Advances the ticker value by {@code time} in {@code timeUnit}. */ @SuppressWarnings("GoodTime") // should accept a java.time.Duration @CanIgnoreReturnValue
Registered: 2024-11-01 12:43 - Last Modified: 2024-10-19 00:26 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
* limitations under the License. */ package okhttp3 import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicLong import java.util.concurrent.atomic.AtomicReference import okhttp3.internal.USER_AGENT import okio.ByteString /** * Exercises the web socket implementation against the
Registered: 2024-11-01 11:42 - Last Modified: 2024-01-08 01:13 - 4.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java
* */ public class CrawlerContext { protected String sessionId; protected Integer activeThreadCount = 0; protected Object activeThreadCountLock = new Object(); protected AtomicLong accessCount = new AtomicLong(0); protected volatile CrawlerStatus status = CrawlerStatus.INITIALIZING; protected UrlFilter urlFilter; protected RuleManager ruleManager;
Registered: 2024-11-10 03:50 - Last Modified: 2024-10-12 01:40 - 4.5K bytes - Viewed (0)