- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 23 for threadFactory (0.07 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
@Override public void setUp() { builder = new ThreadFactoryBuilder(); } public void testThreadFactoryBuilder_defaults() throws InterruptedException { ThreadFactory threadFactory = builder.build(); Thread thread = threadFactory.newThread(monitoredRunnable); checkThreadPoolName(thread, 1); Thread defaultThread = defaultThreadFactory().newThread(monitoredRunnable);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
@Override public void setUp() { builder = new ThreadFactoryBuilder(); } public void testThreadFactoryBuilder_defaults() throws InterruptedException { ThreadFactory threadFactory = builder.build(); Thread thread = threadFactory.newThread(monitoredRunnable); checkThreadPoolName(thread, 1); Thread defaultThread = defaultThreadFactory().newThread(monitoredRunnable);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ThreadFactory threadFactory = mock(ThreadFactory.class); when(executor.getThreadFactory()).thenReturn(threadFactory); ScheduledExecutorService unused = application.getExitingScheduledExecutorService(executor); application.shutdown(); verify(executor).shutdown(); } public void testPlatformThreadFactory_default() { ThreadFactory factory = MoreExecutors.platformThreadFactory();
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) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
return this; } /** * Sets the backing {@link ThreadFactory} for new threads created with this ThreadFactory. Threads * will be created by invoking #newThread(Runnable) on this backing {@link ThreadFactory}. * * @param backingThreadFactory the backing {@link ThreadFactory} which will be delegated to during * thread creation. * @return this for the builder patternCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 29 17:36:00 GMT 2025 - 9.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ThreadFactory threadFactory = mock(ThreadFactory.class); when(executor.getThreadFactory()).thenReturn(threadFactory); ScheduledExecutorService unused = application.getExitingScheduledExecutorService(executor); application.shutdown(); verify(executor).shutdown(); } public void testPlatformThreadFactory_default() { ThreadFactory factory = MoreExecutors.platformThreadFactory();
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) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
) } class RealBackend( threadFactory: ThreadFactory, ) : Backend { val executor = ThreadPoolExecutor( // corePoolSize: 0, // maximumPoolSize: Int.MAX_VALUE, // keepAliveTime: 60L, TimeUnit.SECONDS, SynchronousQueue(), threadFactory, ) override fun nanoTime() = System.nanoTime()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Aug 30 11:30:11 GMT 2025 - 10.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
import okio.Source /** GMT and UTC are equivalent for our purposes. */ @JvmField internal val UTC: TimeZone = TimeZone.getTimeZone("GMT")!! internal fun threadFactory( name: String, daemon: Boolean, ): ThreadFactory = ThreadFactory { runnable -> Thread(runnable, name).apply { isDaemon = daemon } } internal fun HttpUrl.toHostHeader(includeDefaultPort: Boolean = false): String {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10.3K bytes - Click Count (1) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
private static final ThreadFactory threadFactory = new ThreadFactoryBuilder() .setDaemon(true) .setNameFormat("ListenableFutureAdapter-thread-%d") .build(); private static final Executor defaultAdapterExecutor = newCachedThreadPool(threadFactory); private final Executor adapterExecutor;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
src/main/java/jcifs/util/ResourceManager.java
} } private ResourceManager() { ThreadFactory threadFactory = r -> { Thread t = new Thread(r, "ResourceManager-Cleanup"); t.setDaemon(true); return t; }; cleanupExecutor = Executors.newSingleThreadScheduledExecutor(threadFactory); // Add shutdown hook for cleanupCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 16.2K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
} private fun loomThreadFactory(): ThreadFactory { val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null) return Class .forName("java.lang.Thread\$Builder") .getMethod("factory") .invoke(ofVirtual) as ThreadFactory } private fun isLoom(): Boolean = getPlatformSystemProperty() == LOOM_PROPERTY
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0)