- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 283 for waiters (0.54 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)