- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,234 for toRead (0.12 sec)
-
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/DefaultFileWatcherRegistry.java
} } catch (InterruptedException e) { Thread.currentThread().interrupt(); // stop thread } LOGGER.debug("Finished listening to file system change events"); }); thread.setDaemon(true); thread.setName("File watcher consumer"); thread.setUncaughtExceptionHandler((failedThread, exception) -> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 11.2K bytes - Viewed (0) -
src/runtime/testdata/testwinlibthrow/veh.c
ThreadRaiser(void* Context) L12:{ L13: RaiseNoExcept(); L14: return 0; L15:} L16: L17:__declspec(dllexport) L18:void ThreadRaiseNoExcept(void) L19:{ L20: HANDLE thread = CreateThread(0, 0, ThreadRaiser, 0, 0, 0); L21: if (0 != thread) L22: { L23: WaitForSingleObject(thread, INFINITE); L24: CloseHandle(thread); L25: } L26:} ...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 20 18:45:28 UTC 2022 - 470 bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Callables.java
} /** * Wraps the given callable such that for the duration of {@link Callable#call} the thread that is * 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
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/coro.go
gp.coroexit = false mp := gp.m // Track and validate thread-lock interactions. // // The rules with thread-lock interactions are simple. When a coro goroutine is switched to, // the same thread must be used, and the locked state must match with the thread-lock state of // the goroutine which called newcoro. Thread-lock state consists of the thread and the number
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/bindm.go
} //export GoCheckBindM func GoCheckBindM(thread uintptr) { // Wait all threads start if started.Load() != cThreadNum { // Only once for each thread, since it will wait all threads start. started.Add(1) for started.Load() < cThreadNum { runtime.Gosched() } } m := runtime_getm_for_test() mutex.Lock() defer mutex.Unlock() if savedM, ok := cThreadToM[thread]; ok && savedM != m {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 17 21:53:11 UTC 2023 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
} /** * Wraps the given callable such that for the duration of {@link Callable#call} the thread that is * 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
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* * 1. The client thread begins to block on a get() call to a future. * 2. The client thread is interrupted sometime before the result would be * available. * 3. We expect the client's get() to throw an InterruptedException. * 4. We expect the client thread's interrupt state to be false. * 5. The client thread again makes a blocking call to get().
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testRenaming() throws Exception { String oldName = Thread.currentThread().getName(); final Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName"); Callable<@Nullable Void> callable = new Callable<@Nullable Void>() { @Override public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null;
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 void testRenaming() throws Exception { String oldName = Thread.currentThread().getName(); final Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName"); Callable<@Nullable Void> callable = new Callable<@Nullable Void>() { @Override public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order. * * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue. * When a task is {@linkplain Thread#interrupt interrupted}, execution of subsequent tasks * continues. See {@link QueueWorker#workOnQueue} for details. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0)