Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for AtomicLong (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top