Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,935 for thread1 (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top