Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for executeListener (0.13 seconds)

  1. guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

            runnables = null; // allow GC to free listeners even if this stays around for a while.
          }
          while (list != null) {
            executeListener(list.runnable, list.executor);
            list = list.next;
          }
        }
    
        private static void executeListener(Runnable runnable, Executor executor) {
          try {
            executor.execute(runnable);
          } catch (RuntimeException e) {
            log.log(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

            runnables = null; // allow GC to free listeners even if this stays around for a while.
          }
          while (list != null) {
            executeListener(list.runnable, list.executor);
            list = list.next;
          }
        }
    
        private static void executeListener(Runnable runnable, Executor executor) {
          try {
            executor.execute(runnable);
          } catch (RuntimeException e) {
            log.log(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // some of the previously added runnables, but we're OK with that. If we want to change the
        // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
        // it.
        executeListener(runnable, executor);
      }
    
      /**
       * Runs this execution list, executing all existing pairs in the order they were added. However,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

            } while (oldHead != Listener.TOMBSTONE);
          }
        }
        // If we get here then the Listener TOMBSTONE was set, which means the future is done, call
        // the listener.
        executeListener(listener, executor);
      }
    
      /**
       * Sets the result of this {@code Future} unless this {@code Future} has already been cancelled or
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * AbstractFuture.executeListener to do so, since that method would have the ability to continue
         * to execute other listeners.
         *
         * What about RuntimeException? If there is a bug in set()/setValue() that produces one, it will
         * propagate, too, but only as far as AbstractFuture.executeListener, which will catch and log
         * it.
         */
        setResult(transformResult);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
Back to Top