Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for newThread (0.17 sec)

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

                .build()
                .newThread(monitoredRunnable)
                .getUncaughtExceptionHandler());
      }
    
      public void testBuildMutateBuild() {
        ThreadFactory factory1 = builder.setPriority(1).build();
        assertEquals(1, factory1.newThread(monitoredRunnable).getPriority());
    
        ThreadFactory factory2 = builder.setPriority(2).build();
        assertEquals(1, factory1.newThread(monitoredRunnable).getPriority());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  2. 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) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 10 21:56:03 GMT 2023
    - 7.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

                .build()
                .newThread(monitoredRunnable)
                .getUncaughtExceptionHandler());
      }
    
      public void testBuildMutateBuild() {
        ThreadFactory factory1 = builder.setPriority(1).build();
        assertEquals(1, factory1.newThread(monitoredRunnable).getPriority());
    
        ThreadFactory factory2 = builder.setPriority(2).build();
        assertEquals(1, factory1.newThread(monitoredRunnable).getPriority());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  4. 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) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       * fails}.
       */
      protected ScheduledExecutorService executor() {
        @WeakOuter
        class ThreadFactoryImpl implements ThreadFactory {
          @Override
          public Thread newThread(Runnable runnable) {
            return MoreExecutors.newThread(serviceName(), runnable);
          }
        }
        final ScheduledExecutorService executor =
            Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

            new ThreadPoolExecutor(1, 2, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1));
        assertNotNull(application.getExitingExecutorService(executor));
        assertTrue(executor.getThreadFactory().newThread(EMPTY_RUNNABLE).isDaemon());
      }
    
      @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock.
      public void testGetExitingExecutorService_executorDelegatesToOriginal() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (3)
  7. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

          }
        }
      }
    
      /** For use as ThreadFactory in constructors */
      public static class SimpleThreadFactory implements ThreadFactory {
        @Override
        public Thread newThread(Runnable r) {
          return new Thread(r);
        }
      }
    
      public interface TrackedRunnable extends Runnable {
        boolean isDone();
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

       * Executor#execute(Runnable) execute()} method is called when this service is started and
       * stopped, and should return promptly.
       */
      protected Executor executor() {
        return command -> MoreExecutors.newThread(threadNameSupplier.get(), command).start();
      }
    
      @Override
      public String toString() {
        return serviceName() + " [" + state() + "]";
      }
    
      @Override
      public final boolean isRunning() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 17 13:59:28 GMT 2023
    - 5.3K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

          @Override
          public void run() {}
        }
    
        public static final class DummyThreadFactory implements ThreadFactory, Serializable {
          @Override
          public Thread newThread(Runnable r) {
            return new Thread(r);
          }
        }
    
        public static final class DummyExecutor implements Executor, Serializable {
          @Override
          public void execute(Runnable command) {}
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 21K bytes
    - Viewed (1)
  10. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

          @Override
          public void run() {}
        }
    
        public static final class DummyThreadFactory implements ThreadFactory, Serializable {
          @Override
          public Thread newThread(Runnable r) {
            return new Thread(r);
          }
        }
    
        public static final class DummyExecutor implements Executor, Serializable {
          @Override
          public void execute(Runnable command) {}
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 20.5K bytes
    - Viewed (0)
Back to top