Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for rollback (0.17 sec)

  1. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * java.util.concurrent.CompletableFuture#thenAcceptAsync}.
       *
       * @param callback The callback to invoke when this {@code Future} is completed.
       * @param executor The executor to run {@code callback} when the future completes.
       */
      public final void addCallback(FutureCallback<? super V> callback, Executor executor) {
        Futures.addCallback(this, callback, executor);
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 11 19:08:44 GMT 2023
    - 18.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/base/OptionalTest.java

      public void testOr_supplier_present() {
        assertEquals("a", Optional.of("a").or(Suppliers.ofInstance("fallback")));
      }
    
      public void testOr_supplier_absent() {
        assertEquals("fallback", Optional.absent().or(Suppliers.ofInstance("fallback")));
      }
    
      public void testOr_nullSupplier_absent() {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/eventbus/EventBusTest.java

       * for bridge methods.
       */
      public void testRegistrationWithBridgeMethod() {
        final AtomicInteger calls = new AtomicInteger();
        bus.register(
            new Callback<String>() {
              @Subscribe
              @Override
              public void call(String s) {
                calls.incrementAndGet();
              }
            });
    
        bus.post("hello");
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

       * for bridge methods.
       */
      public void testRegistrationWithBridgeMethod() {
        final AtomicInteger calls = new AtomicInteger();
        bus.register(
            new Callback<String>() {
              @Subscribe
              @Override
              public void call(String s) {
                calls.incrementAndGet();
              }
            });
    
        bus.post("hello");
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/base/OptionalTest.java

      public void testOr_supplier_present() {
        assertEquals("a", Optional.of("a").or(Suppliers.ofInstance("fallback")));
      }
    
      public void testOr_supplier_absent() {
        assertEquals("fallback", Optional.absent().or(Suppliers.ofInstance("fallback")));
      }
    
      public void testOr_nullSupplier_absent() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/Striped64.java

      /** Table of cells. When non-null, size is a power of 2. */
      @CheckForNull transient volatile Cell[] cells;
    
      /**
       * Base value, used mainly when there is no contention, but also as a fallback during table
       * initialization races. Updated via CAS.
       */
      transient volatile long base;
    
      /** Spinlock (locked via CAS) used when resizing and/or creating Cells. */
      transient volatile int busy;
    
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Service.java

       * logged.
       *
       * @param listener the listener to run when the service changes state is complete
       * @param executor the executor in which the listeners callback methods will be run. For fast,
       *     lightweight listeners that would be safe to execute in any thread, consider {@link
       *     MoreExecutors#directExecutor}.
       * @since 13.0
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 10.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/MoreObjects.java

       *
       * <p><b>Note:</b> if {@code first} is represented as an {@link Optional}, this can be
       * accomplished with {@link Optional#or(Object) first.or(second)}. That approach also allows for
       * lazy evaluation of the fallback instance, using {@link Optional#or(Supplier)
       * first.or(supplier)}.
       *
       * <p><b>Java 9 users:</b> use {@code java.util.Objects.requireNonNullElse(first, second)}
       * instead.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri Oct 13 14:11:58 GMT 2023
    - 15.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
Back to top