Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for unbuffered (0.13 sec)

  1. doc/godebug.md

    enabled by default on listerners. Using multipathtcp="0" reverts to the
    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. doc/go1.17_spec.html

    make(chan int, 100)
    </pre>
    
    <p>
    The capacity, in number of elements, sets the size of the buffer in the channel.
    If the capacity is zero or absent, the channel is unbuffered and communication
    succeeds only when both a sender and receiver are ready. Otherwise, the channel
    is buffered and communication succeeds without blocking if the buffer
    is not full (sends) or not empty (receives).
    A <code>nil</code> channel is never ready for communication.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  3. doc/go_spec.html

    make(chan int, 100)
    </pre>
    
    <p>
    The capacity, in number of elements, sets the size of the buffer in the channel.
    If the capacity is zero or absent, the channel is unbuffered and communication
    succeeds only when both a sender and receiver are ready. Otherwise, the channel
    is buffered and communication succeeds without blocking if the buffer
    is not full (sends) or not empty (receives).
    A <code>nil</code> channel is never ready for communication.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/ByteSink.java

       *
       * @throws IOException if an I/O error occurs while opening the stream
       */
      public abstract OutputStream openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 28 16:55:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. src/bufio/bufio_test.go

    		t.Error("expected flush error, got nil")
    	}
    	if _, err := wr.ReadFrom(strings.NewReader("test2")); err == nil {
    		t.Fatal("expected error, got nil")
    	}
    	if buffered := wr.Buffered(); buffered != wantBuffered {
    		t.Fatalf("Buffered = %v; want %v", buffered, wantBuffered)
    	}
    }
    
    func BenchmarkReaderCopyOptimal(b *testing.B) {
    	// Optimal case is where the underlying reader implements io.WriterTo
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/CharSink.java

       *
       * @throws IOException if an I/O error occurs while opening the writer
       */
      public abstract Writer openStream() throws IOException;
    
      /**
       * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not
       * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    // does not exist in enough quorum nodes.
    func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) {
    	restClnts, _ := ds.GetLockers()
    
    	// Create buffered channel of size equal to total number of nodes.
    	ch := make(chan refreshResult, len(restClnts))
    	var wg sync.WaitGroup
    
    	args := LockArgs{
    		UID: id,
    	}
    
    	for index, c := range restClnts {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. cmd/storage-rest-client.go

    }
    
    // where we keep old *Readers
    var readMsgpReaderPool = sync.Pool{New: func() interface{} { return &msgp.Reader{} }}
    
    // mspNewReader returns a *Reader that reads from the provided reader.
    // The reader will be buffered.
    // Return with readMsgpReaderPoolPut when done.
    func msgpNewReader(r io.Reader) *msgp.Reader {
    	p := readMsgpReaderPool.Get().(*msgp.Reader)
    	if p.R == nil {
    		p.R = xbufio.NewReaderSize(r, 32<<10)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    	}
    	return n, err
    }
    
    // diskHealthReader provides a wrapper that will update disk health on
    // ctx, on every successful read.
    // This should only be used directly at the os/syscall level,
    // otherwise buffered operations may return false health checks.
    func diskHealthReader(ctx context.Context, r io.Reader) io.Reader {
    	// Check if context has a disk health check.
    	tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. cmd/peer-rest-server.go

    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top