Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for Deadpond (0.12 sec)

  1. internal/ringbuffer/ring_buffer.go

    	size      int
    	r         int // next position to read
    	w         int // next position to write
    	isFull    bool
    	err       error
    	block     bool
    	mu        sync.Mutex
    	wg        sync.WaitGroup
    	readCond  *sync.Cond // Signaled when data has been read.
    	writeCond *sync.Cond // Signaled when data has been written.
    }
    
    // New returns a new RingBuffer whose buffer has the given size.
    func New(size int) *RingBuffer {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top