channel

Documentation

Overview

Package channel 提供一些方便的 chan 操作封装

Index

• func ReadNonBlocked[T any](ch <-chan T) (v T, empty, emptyAndClosed bool)
• func WriteNonBlocked[T any](ch chan<- T, v T) (full, closed bool)

Functions

func ReadNonBlocked

func ReadNonBlocked[T any](ch <-chan T) (v T, empty, emptyAndClosed bool)

ReadNonBlocked 非阻塞地从一个 chan 中读出数据。当读取失败时返回

func WriteNonBlocked

func WriteNonBlocked[T any](ch chan<- T, v T) (full, closed bool)

WriteNonBlocked 非阻塞地向一个 chan 中写入数据, 当写入失败时返回