- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,935 for thread1 (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
/** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until * the already-requested ones are in service, otherwise we might create more threads than we need. * * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/os/exec/exec_linux_test.go
if os.Getenv("GO_EXEC_TEST_PID") == "" { return } // Start some threads. 10 is arbitrary but intended to be enough // to ensure that the code won't have to create any threads itself. // In particular this should be more than the number of threads // the garbage collector might create. const threads = 10 var wg sync.WaitGroup wg.Add(threads) ts := syscall.NsecToTimespec((100 * time.Microsecond).Nanoseconds())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 26 14:49:07 UTC 2022 - 1.2K bytes - Viewed (0) -
docs/contribute/concurrency.md
#### Do-stuff-later pool Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads. ### Locks
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
} /** * Add a shutdown hook to wait for thread completion in the given {@link ExecutorService service}. * This is useful if the given service uses daemon threads, and we want to keep the JVM from * exiting immediately on shutdown, instead giving these daemon threads a chance to terminate * normally. * * @param service ExecutorService which uses daemon threads
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
* running will have the given name. * * @param callable The callable to wrap * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once * for each invocation of the wrapped callable. */ @J2ktIncompatible @GwtIncompatible // threads static <T extends @Nullable Object> Callable<T> threadRenaming(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
src/runtime/os_linux.go
// This function depends on several properties: // // 1. All OS threads that already exist are associated with an M in // allm. i.e., we won't miss any pre-existing threads. // 2. All Ms listed in allm will eventually have an OS thread exist. // i.e., they will set procid and be able to receive signals. // 3. OS threads created after we read allm will clone from a thread // that has executed the system call. i.e., they inherit the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Callables.java
* running will have the given name. * * @param callable The callable to wrap * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once * for each invocation of the wrapped callable. */ @J2ktIncompatible @GwtIncompatible // threads static <T extends @Nullable Object> Callable<T> threadRenaming(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
* * <p>Implementations are not guaranteed to be completely thread-safe. * However, the implementations: * <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li> * <li>should allow stopping or requesting stopping from a different thread than receiving/dispatching</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0)