- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,935 for thread1 (0.23 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test, // so there is no object state put at risk by stopping the threads abruptly. In some cases a test // may put a thread into an uninterruptible operation intentionally, so there is no other way to // clean up these threads. @SuppressWarnings("deprecation") @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
/** Checks that the threads do not terminate within the given millisecond delay. */ void assertThreadsStayAlive(long millis, Thread... threads) { try { // No need to optimize the failing case via Thread.join. delay(millis); for (Thread thread : threads) assertTrue(thread.isAlive()); } catch (InterruptedException ie) { fail("Unexpected InterruptedException"); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
/** Checks that the threads do not terminate within the given millisecond delay. */ void assertThreadsStayAlive(long millis, Thread... threads) { try { // No need to optimize the failing case via Thread.join. delay(millis); for (Thread thread : threads) assertTrue(thread.isAlive()); } catch (InterruptedException ie) { fail("Unexpected InterruptedException"); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
src/internal/runtime/atomic/types_64bit.go
package atomic // LoadAcquire is a partially unsynchronized version // of Load that relaxes ordering constraints. Other threads // may observe operations that precede this operation to // occur after it, but no operation that occurs after it // on this thread can be observed to occur before it. // // WARNING: Use sparingly and with great care. // //go:nosplit func (u *Uint64) LoadAcquire() uint64 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
src/runtime/os3_solaris.go
} func pthread_create(thread *pthread, attr *pthreadattr, fn uintptr, arg unsafe.Pointer) int32 { return int32(sysvicall4(&libc_pthread_create, uintptr(unsafe.Pointer(thread)), uintptr(unsafe.Pointer(attr)), uintptr(fn), uintptr(arg))) } func pthread_self() pthread { return pthread(sysvicall0(&libc_pthread_self)) } func signalM(mp *m, sig int) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 17.6K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/bindm.c
//go:build !plan9 && !windows #include <stdint.h> #include <pthread.h> #include <unistd.h> #include "_cgo_export.h" #define CTHREADS 2 #define CHECKCALLS 100 static void* checkBindMThread(void* thread) { int i; for (i = 0; i < CHECKCALLS; i++) { GoCheckBindM((uintptr_t)thread); usleep(1); } return NULL; } void CheckBindM() { int i; pthread_t s[CTHREADS]; for (i = 0; i < CTHREADS; i++) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 17 21:53:11 UTC 2023 - 692 bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ThreadFactoryImpl.java
} @Override public Thread newThread(Runnable r) { Thread thread = new Thread(r); thread.setName(nextThreadName()); thread.setContextClassLoader(contextClassloader); return thread; } private String nextThreadName() { long count = counter.incrementAndGet(); return count == 1 ? displayName : displayName + " Thread " + count; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.6K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue1435.go
} if !foundAThread { return fmt.Errorf("found no thread /proc/<TID>/status files for process %q", expectedProc) } return nil } // test1435 test 9 glibc implemented setuid/gid syscall functions are // mapped. This test is a slightly more expansive test than that of // src/syscall/syscall_linux_test.go:TestSetuidEtc() insofar as it // launches concurrent threads from C code via CGo and validates that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jul 28 21:31:41 UTC 2023 - 7.5K bytes - Viewed (0) -
src/runtime/os_darwin.go
writeErrStr(failthreadcreate) exit(1) } mp.g0.stack.hi = stacksize // for mstart // Tell the pthread library we won't join with this thread. if pthread_attr_setdetachstate(&attr, _PTHREAD_CREATE_DETACHED) != 0 { writeErrStr(failthreadcreate) exit(1) } // Finally, create the thread. It starts at mstart_stub, which does some low-level // setup and then calls mstart. var oset sigset
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0)