Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 283 for waiters (0.54 sec)

  1. src/syscall/syscall_linux_test.go

    			// needed, based on the number of available
    			// unlocked OS threads at the time waiter
    			// calls runtime.LockOSThread(), but the goal
    			// of doing this every time through the loop
    			// is to race thread creation with v.fn(want)
    			// being executed. Via the once boolean we
    			// also encourage one in 5 waiters to return
    			// locked after participating in only one
    			// question response sequence. This allows the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 23K bytes
    - Viewed (0)
  2. src/runtime/runtime2.go

    	// because c was closed.
    	success bool
    
    	// waiters is a count of semaRoot waiting list other than head of list,
    	// clamped to a uint16 to fit in unused space.
    	// Only meaningful at the head of the list.
    	// (If we wanted to be overly clever, we could store a high 16 bits
    	// in the second entry in the list.)
    	waiters uint16
    
    	parent   *sudog // semaRoot binary tree
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go

    	}
    	w.Header().Set("Content-Type", contentType)
    	w.WriteHeader(statusCode)
    	// Flush headers, if possible
    	if flusher, ok := w.(http.Flusher); ok {
    		flusher.Flush()
    	}
    	writer := w.(io.Writer)
    	if flush {
    		writer = flushwriter.Wrap(w)
    	}
    	io.Copy(writer, out)
    }
    
    // SerializeObject renders an object in the content type negotiated by the client using the provided encoder.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 18:21:43 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  6. src/archive/tar/writer.go

    	"path"
    	"slices"
    	"strings"
    	"time"
    )
    
    // Writer provides sequential writing of a tar archive.
    // [Writer.WriteHeader] begins a new file with the provided [Header],
    // and then Writer can be treated as an io.Writer to supply that file's data.
    type Writer struct {
    	w    io.Writer
    	pad  int64      // Amount of padding to write after current file entry
    	curr fileWriter // Writer for current file entry
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. src/mime/quotedprintable/writer.go

    import "io"
    
    const lineMaxLen = 76
    
    // A Writer is a quoted-printable writer that implements [io.WriteCloser].
    type Writer struct {
    	// Binary mode treats the writer's input as pure binary and processes end of
    	// line bytes as binary data.
    	Binary bool
    
    	w    io.Writer
    	i    int
    	line [78]byte
    	cr   bool
    }
    
    // NewWriter returns a new [Writer] that writes to w.
    func NewWriter(w io.Writer) *Writer {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 16:12:35 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. src/internal/trace/raw/writer.go

    // NewWriter creates a new byte format writer.
    func NewWriter(w io.Writer, v version.Version) (*Writer, error) {
    	_, err := version.WriteHeader(w, v)
    	return &Writer{w: w, v: v, specs: v.Specs()}, err
    }
    
    // WriteEvent writes a single event to the trace wire format stream.
    func (w *Writer) WriteEvent(e Event) error {
    	// Check version.
    	if e.Version != w.v {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. src/mdo/writer.vm

        } //-- void setFileComment(String)
    
        /**
         * Method write.
         *
         * @param writer a writer object
         * @param ${rootLcapName} a ${root.name} object
         * @throws java.io.IOException java.io.IOException if any
         */
        public void write(Writer writer, ${root.name} ${rootLcapName}) throws java.io.IOException {
            XmlSerializer serializer = new MXSerializer();
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Thu Sep 14 11:48:15 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  10. src/compress/lzw/writer.go

    // is a *[Writer].
    func NewWriter(w io.Writer, order Order, litWidth int) io.WriteCloser {
    	return newWriter(w, order, litWidth)
    }
    
    func newWriter(dst io.Writer, order Order, litWidth int) *Writer {
    	w := new(Writer)
    	w.init(dst, order, litWidth)
    	return w
    }
    
    func (w *Writer) init(dst io.Writer, order Order, litWidth int) {
    	switch order {
    	case LSB:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 13:32:40 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top