Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 237 for Runnables (0.53 seconds)

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

        ListenableFuture<?> future;
    
        ThrowingRunnable runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleAtFixedRate(runnable, 1, 1, MILLISECONDS);
        assertExecutionException(future, ex);
        assertEquals(5, runnable.count);
        assertEquals(0, delegate.getQueue().size());
    
        runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleWithFixedDelay(runnable, 1, 1, MILLISECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/Callables.java

              boolean unused = trySetName(oldName, currentThread);
            }
          }
        };
      }
    
      /**
       * Wraps the given runnable such that for the duration of {@link Runnable#run} the thread that is
       * running with have the given name.
       *
       * @param task The Runnable to wrap
       * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/app/web/admin/sereq/AdminSereqAction.java

         *
         * @param runnable optional runnable to execute before rendering (can be null)
         * @return HTML response for the search request list page
         */
        private HtmlResponse asListHtml(final Runnable runnable) {
            if (runnable != null) {
                runnable.run();
            }
            return asHtml(path_AdminSereq_AdminSereqJsp).useForm(UploadForm.class);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  4. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
        Runnable runnable =
            () -> {
              throw new RuntimeException("Oh no!");
            };
    
        Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
        assertThrows(ExecutionException.class, future::get);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  5. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
        Runnable runnable =
            () -> {
              throw new RuntimeException("Oh no!");
            };
    
        Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
        assertThrows(ExecutionException.class, future::get);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  6. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AnonymousClassesFilteringTest.kt

                        public void some() {}
                    }
                """,
                v2 = """
                    public class Source {
                        public void some() {
                            Runnable anon = new Runnable() {
                                @Override
                                public void run() {}
                            };
                            anon.run();
                        }
                    }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 1.8K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/reflect/AbstractInvocationHandlerTest.java

            .addEqualityGroup(newDelegatingList(LIST2))
            .addEqualityGroup(
                newProxyWithEqualsForInterfaces(List.class, Runnable.class),
                newProxyWithEqualsForInterfaces(List.class, Runnable.class))
            .addEqualityGroup(newProxyWithEqualsForInterfaces(Runnable.class, List.class))
            .addEqualityGroup(
                newDelegatingListWithEquals(LIST1),
                newDelegatingListWithEquals(LIST1),
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Thread newThread(String name, Runnable runnable) {
        checkNotNull(name);
        checkNotNull(runnable);
        // TODO(b/139726489): Confirm that null is impossible here.
        Thread result = requireNonNull(platformThreadFactory().newThread(runnable));
        try {
          result.setName(name);
        } catch (SecurityException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/collect/AbstractHashFloodingTest.java

        private final String delegateString;
        private final Runnable onHashCode;
        private final Runnable onEquals;
        private final Runnable onCompareTo;
    
        CountsHashCodeAndEquals(
            String delegateString, Runnable onHashCode, Runnable onEquals, Runnable onCompareTo) {
          this.delegateString = delegateString;
          this.onHashCode = onHashCode;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 9K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/ForwardingObjectTesterTest.java

      private abstract static class FailToForward extends ForwardingObject implements Runnable {
        @Override
        public void run() {}
      }
    
      private abstract static class ForwardToDelegate extends ForwardingObject implements Runnable {
        @Override
        public void run() {
          delegate().run();
        }
    
        @Override
        protected abstract Runnable delegate();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 1.9K bytes
    - Click Count (0)
Back to Top