Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for getAndSet (0.06 sec)

  1. guava/src/com/google/common/collect/AbstractMapBasedMultiset.java

        Count existingCounter;
        int oldCount;
        if (count == 0) {
          existingCounter = backingMap.remove(element);
          oldCount = getAndSet(existingCounter, count);
        } else {
          existingCounter = backingMap.get(element);
          oldCount = getAndSet(existingCounter, count);
    
          if (existingCounter == null) {
            backingMap.put(element, new Count(count));
          }
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

          }
          assertBitEquals(x, at.get());
          prev = x;
        }
      }
    
      /** getAndSet returns previous value and sets to given value */
      public void testGetAndSet() {
        double prev = Math.E;
        AtomicDouble at = new AtomicDouble(prev);
        for (double x : VALUES) {
          assertBitEquals(prev, at.getAndSet(x));
          prev = x;
        }
      }
    
      /** getAndAdd returns previous value and adds given value */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

            prev = x;
          }
        }
      }
    
      /** getAndSet returns previous value and sets to given value at given index */
      public void testGetAndSet() {
        AtomicDoubleArray aa = new AtomicDoubleArray(SIZE);
        for (int i : new int[] {0, SIZE - 1}) {
          double prev = 0.0;
          for (double x : VALUES) {
            assertBitEquals(prev, aa.getAndSet(i, x));
            prev = x;
          }
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            // not all.  See the test cases for examples on how this can happen.
            try {
              ((Thread) currentRunner).interrupt();
            } finally {
              Runnable prev = getAndSet(DONE);
              if (prev == PARKED) {
                LockSupport.unpark((Thread) currentRunner);
              }
            }
          }
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            // not all.  See the test cases for examples on how this can happen.
            try {
              ((Thread) currentRunner).interrupt();
            } finally {
              Runnable prev = getAndSet(DONE);
              if (prev == PARKED) {
                LockSupport.unpark((Thread) currentRunner);
              }
            }
          }
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/Crawler.java

            }
    
            if (exitCode != Constants.EXIT_OK) {
                System.exit(exitCode);
            }
        }
    
        private static void destroyContainer() {
            if (running.getAndSet(false)) {
                TimeoutManager.getInstance().stop();
                if (logger.isDebugEnabled()) {
                    logger.debug("Destroying LaContainer...");
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SystemHelper.java

            updateConfigListenerMap.put(name, listener);
        }
    
        public boolean isChangedClusterState(final int status) {
            return previousClusterState.getAndSet(status) != status;
        }
    
        public ActionValidator<FessMessages> createValidator(final RequestManager requestManager,
                final UserMessagesCreator<FessMessages> messagesCreator, final Class<?>[] runtimeGroups) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Oct 17 12:10:08 UTC 2024
    - 27.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       *
       * <p>Triggers test case failure if interrupt status is set in the main thread.
       */
      @Override
      public void tearDown() throws Exception {
        Throwable t = threadFailure.getAndSet(null);
        if (t != null) {
          if (t instanceof Error) throw (Error) t;
          else if (t instanceof RuntimeException) throw (RuntimeException) t;
          else if (t instanceof Exception) throw (Exception) t;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       *
       * <p>Triggers test case failure if interrupt status is set in the main thread.
       */
      @Override
      public void tearDown() throws Exception {
        Throwable t = threadFailure.getAndSet(null);
        if (t != null) {
          if (t instanceof Error) throw (Error) t;
          else if (t instanceof RuntimeException) throw (RuntimeException) t;
          else if (t instanceof Exception) throw (Exception) t;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
Back to top