Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Threads (0.18 sec)

  1. misc/cgo/gmp/fib.go

    // that pass integers back and forth.  No actual
    // concurrency, just threads and synchronization
    // and foreign code on multiple pthreads.
    
    package main
    
    import (
    	big "."
    	"runtime"
    )
    
    func fibber(c chan *big.Int, out chan string, n int64) {
    	// Keep the fibbers in dedicated operating system
    	// threads, so that this program tests coordination
    	// between pthreads and not just goroutines.
    	runtime.LockOSThread()
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Apr 10 22:32:35 GMT 2023
    - 919 bytes
    - Viewed (0)
  2. src/cmd/cgo/internal/test/issue18146.go

    		var rlim syscall.Rlimit
    		if syscall.Getrlimit(nproc, &rlim) == nil {
    			max := int(rlim.Cur) / (threads + 5)
    			if attempts > max {
    				t.Logf("lowering attempts from %d to %d for RLIMIT_NPROC", attempts, max)
    				attempts = max
    			}
    		}
    	}
    
    	if os.Getenv("test18146") == "exec" {
    		runtime.GOMAXPROCS(1)
    		for n := threads; n > 0; n-- {
    			go func() {
    				for {
    					_ = md5.Sum([]byte("Hello, !"))
    				}
    			}()
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Tue Sep 05 23:35:32 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  3. 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
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Jul 28 21:31:41 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  4. src/archive/zip/struct.go

    	creatorFAT    = 0
    	creatorUnix   = 3
    	creatorNTFS   = 11
    	creatorVFAT   = 14
    	creatorMacOSX = 19
    
    	// Version numbers.
    	zipVersion20 = 20 // 2.0
    	zipVersion45 = 45 // 4.5 (reads and writes zip64 archives)
    
    	// Limits for non zip64 files.
    	uint16max = (1 << 16) - 1
    	uint32max = (1 << 32) - 1
    
    	// Extra header IDs.
    	//
    	// IDs 0..31 are reserved for official use by PKWARE.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 12.1K bytes
    - Viewed (0)
  5. src/bufio/scan.go

    // immediately stops the scanning.
    //
    // Otherwise, the [Scanner] advances the input. If the token is not nil,
    // the [Scanner] returns it to the user. If the token is nil, the
    // Scanner reads more data and continues scanning; if there is no more
    // data--if atEOF was true--the [Scanner] returns. If the data does not
    // yet hold a complete token, for instance if it has no newline while
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Oct 23 09:06:30 GMT 2023
    - 14.2K bytes
    - Viewed (0)
  6. src/archive/zip/reader.go

    	if b.uint32() != 1 { // total number of disks
    		return -1, nil // the file is not a valid zip64-file
    	}
    	return int64(p), nil
    }
    
    // readDirectory64End reads the zip64 directory end and updates the
    // directory end with the zip64 directory end values.
    func readDirectory64End(r io.ReaderAt, offset int64, d *directoryEnd) (err error) {
    	buf := make([]byte, directory64EndLen)
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  7. src/cmd/cgo/doc.go

    When using cgo, Go must not assume that it owns all details of the
    process. In particular it needs to coordinate with C in the use of
    threads and thread-local storage. The runtime package declares a few
    variables:
    
    	var (
    		iscgo             bool
    		_cgo_init         unsafe.Pointer
    		_cgo_thread_start unsafe.Pointer
    	)
    
    Any package using cgo imports "runtime/cgo", which provides
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Sun Mar 31 09:02:45 GMT 2024
    - 42.1K bytes
    - Viewed (0)
  8. src/bytes/reader_test.go

    	withOut.n, withOut.err = io.Copy(discard, justReader{NewReader(nil)})
    	if with != withOut {
    		t.Errorf("behavior differs: with = %#v; without: %#v", with, withOut)
    	}
    }
    
    // tests that Len is affected by reads, but Size is not.
    func TestReaderLenSize(t *testing.T) {
    	r := NewReader([]byte("abc"))
    	io.CopyN(io.Discard, r, 1)
    	if r.Len() != 2 {
    		t.Errorf("Len = %d; want 2", r.Len())
    	}
    	if r.Size() != 3 {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Viewed (0)
  9. src/archive/tar/writer.go

    //
    // If the current file is sparse and r is an io.ReadSeeker,
    // then readFrom uses Seek to skip past holes defined in Header.SparseHoles,
    // assuming that skipped regions are all NULs.
    // This always reads the last byte to ensure r is the right size.
    //
    // TODO(dsnet): Re-export this when adding sparse file support.
    // See https://golang.org/issue/22735
    func (tw *Writer) readFrom(r io.Reader) (int64, error) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 19.6K bytes
    - Viewed (0)
  10. src/archive/zip/zip_test.go

    type repeatedByte struct {
    	off int64
    	b   byte
    	n   int64
    }
    
    // rleBuffer is a run-length-encoded byte buffer.
    // It's an io.Writer (like a bytes.Buffer) and also an io.ReaderAt,
    // allowing random-access reads.
    type rleBuffer struct {
    	buf []repeatedByte
    }
    
    func (r *rleBuffer) Size() int64 {
    	if len(r.buf) == 0 {
    		return 0
    	}
    	last := &r.buf[len(r.buf)-1]
    	return last.off + last.n
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 19.5K bytes
    - Viewed (0)
Back to top