Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 237 for Runnables (0.05 seconds)

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

      private static final TimeUnit UNIT = MILLISECONDS;
    
      // Unique runnable object used for comparison.
      @SuppressWarnings("AnonymousToLambda")
      final Runnable testRunnable =
          new Runnable() {
            @Override
            public void run() {}
          };
    
      boolean called = false;
    
      private void assertSingleCallWithCorrectParameters(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

      private static final TimeUnit UNIT = MILLISECONDS;
    
      // Unique runnable object used for comparison.
      @SuppressWarnings("AnonymousToLambda")
      final Runnable testRunnable =
          new Runnable() {
            @Override
            public void run() {}
          };
    
      boolean called = false;
    
      private void assertSingleCallWithCorrectParameters(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

              public String get(long time, TimeUnit unit) {
                throw new CancellationException(); // BAD!!
              }
    
              @Override
              public void addListener(Runnable runnable, Executor executor) {
                executor.execute(runnable);
              }
            };
        future.setFuture(badFuture);
        ExecutionException expected = getExpectingExecutionException(future);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        AtomicLong count = (nameFormat != null) ? new AtomicLong(0) : null;
        return new ThreadFactory() {
          @Override
          public Thread newThread(Runnable runnable) {
            Thread thread = backingThreadFactory.newThread(runnable);
            // TODO(b/139735208): Figure out what to do when the factory returns null.
            requireNonNull(thread);
            if (nameFormat != null) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. build-logic/buildquality/src/main/kotlin/gradlebuild.arch-test.gradle.kts

                }
            }
        }
    }
    
    tasks.codeQuality.configure {
        dependsOn(testing.suites.named("archTest"))
    }
    
    fun notForAccessorGeneration(runnable: Runnable) {
        if (project.name != "gradle-kotlin-dsl-accessors" && project.name != "test") {
            runnable.run()
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Feb 10 08:11:56 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      }
    
      /** The number of elements to place in collections, arrays, etc. */
      static final int SIZE = 20;
    
      /** Returns a new started daemon Thread running the given runnable. */
      final Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

          return true;
        }
    
        @Override
        public void execute(Runnable runnable) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public void shutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

    @GwtIncompatible
    @J2ktIncompatible
    final class InterruptionUtil {
      private static final Logger logger = Logger.getLogger(InterruptionUtil.class.getName());
    
      /** Runnable which will interrupt the target thread repeatedly when run. */
      private static final class Interruptenator implements Runnable {
        private final Thread interruptee;
        private volatile boolean shouldStop = false;
    
        Interruptenator(Thread interruptee) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 15:38:30 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt

      }
    
      @JvmStatic
      fun threadFactory(name: String): ThreadFactory =
        object : ThreadFactory {
          private var nextId = 1
    
          override fun newThread(runnable: Runnable): Thread = Thread(runnable, "$name-${nextId++}")
        }
    }
    
    fun getEnv(name: String) = System.getenv(name)
    
    val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  10. android/guava-testlib/test/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilderTest.java

          return Collections.<Class<? extends AbstractTester>>singletonList(MyTester.class);
        }
      }
    
      public void testLifecycle() {
        boolean[] setUp = {false};
        Runnable setUpRunnable = () -> setUp[0] = true;
    
        boolean[] tearDown = {false};
        Runnable tearDownRunnable = () -> tearDown[0] = true;
    
        MyTestSuiteBuilder builder = new MyTestSuiteBuilder();
        Test test =
            builder
                .usingGenerator("yam")
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 2.1K bytes
    - Click Count (0)
Back to Top