getAndIncrement - Code Search

maven-core/src/main/java/org/apache/maven/lifecycle/internal/BuildThreadFactory.java

    private static final String PREFIX = "BuilderThread";

    @Override
    public Thread newThread(Runnable r) {
        return new Thread(r, String.format("%s-%d", PREFIX, id.getAndIncrement()));
    }

Java

- Registered: Sun May 05 03:35:11 GMT 2024

- Last Modified: Wed Jan 10 12:55:54 GMT 2024

- 1.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java

    assertEquals(0L, map.get(key));
    assertFalse(map.containsKey(key));

    assertEquals(0L, map.getAndIncrement(key));
    assertEquals(1L, map.get(key));

    assertEquals(1L, map.getAndDecrement(key));
    assertEquals(0L, map.get(key));
    assertTrue(map.containsKey(key));

    assertEquals(0L, map.getAndIncrement(key));
    assertEquals(1L, map.get(key));
  }

  public void testDecrementAndGet() {

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 17.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java

    assertEquals(0L, map.get(key));
    assertFalse(map.containsKey(key));

    assertEquals(0L, map.getAndIncrement(key));
    assertEquals(1L, map.get(key));

    assertEquals(1L, map.getAndDecrement(key));
    assertEquals(0L, map.get(key));
    assertTrue(map.containsKey(key));

    assertEquals(0L, map.getAndIncrement(key));
    assertEquals(1L, map.get(key));
  }

  public void testDecrementAndGet() {

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 17.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                      case 2:
                        map.addAndGet(key, delta);
                        threadSum += delta;
                        break;
                      case 3:
                        map.getAndIncrement(key);
                        threadSum++;
                        break;
                      case 4:
                        map.getAndDecrement(key);
                        threadSum--;

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 4.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

                      case 2:
                        map.addAndGet(key, delta);
                        threadSum += delta;
                        break;
                      case 3:
                        map.getAndIncrement(key);
                        threadSum++;
                        break;
                      case 4:
                        map.getAndDecrement(key);
                        threadSum--;

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 4.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

                indexingHelper.sendDocuments(searchEngineClient, docList);
            }
            executeTime += processingTime;
        }

        documentSize.getAndIncrement();

        if (logger.isDebugEnabled()) {
            logger.debug("The number of an added document is {}.", documentSize.get());
        }

    }

Java

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 7.9K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

      for (int i = 0; i < passedArgs.length; i++) {
        assertEquals(
            "Parameter #" + i + " of " + method + " not forwarded", passedArgs[i], args[i]);
      }
      called.getAndIncrement();
      return returnValue;
    }

    void testInteraction(Function<? super T, ? extends T> wrapperFunction) {
      T proxy = Reflection.newProxy(interfaceType, this);

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Thu Feb 08 17:31:55 GMT 2024

- 9.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

      for (int i = 0; i < passedArgs.length; i++) {
        assertEquals(
            "Parameter #" + i + " of " + method + " not forwarded", passedArgs[i], args[i]);
      }
      called.getAndIncrement();
      return returnValue;
    }

    void testInteraction(Function<? super T, ? extends T> wrapperFunction) {
      T proxy = Reflection.newProxy(interfaceType, this);

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Feb 08 17:31:55 GMT 2024

- 9.1K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

    override fun onStream(stream: Http2Stream) {
      val peekedResponse = dispatcher.peek()
      if (peekedResponse.socketPolicy is ResetStreamAtStart) {
        dispatchBookkeepingRequest(sequenceNumber.getAndIncrement(), socket)
        stream.close(ErrorCode.fromHttp2(peekedResponse.socketPolicy.http2ErrorCode)!!, null)
        return
      }

      val request = readRequest(stream)
      atomicRequestCount.incrementAndGet()

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sun Mar 31 17:16:15 GMT 2024

- 37.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/base/SuppliersTest.java

                            + " synchronizing on supplier"));
                break;
              }
              Thread.yield();
            }
            count.getAndIncrement();
            return Boolean.TRUE;
          }
        };

    final Supplier<Boolean> memoizedSupplier = memoizer.apply(supplier);

    for (int i = 0; i < numThreads; i++) {
      threads[i] =

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Fri Feb 09 15:49:48 GMT 2024

- 18.1K bytes

- Viewed (0)

Search Options