type Conn struct{conn net.Conn // 底层网络连接isServer bool// 如果这个连接作为服务器端的连接则为true，如果是客户端则为falsesubprotocol string// 代表WebSocket连接中协商的子协议// Write fields （写操作相关字段）mu chanstruct{}// used as mutex to protect write to conn（用作互斥锁保护对连接的写操作）writeBuf []byte// frame is constructed in this buffer.(字节切片，用于构造要写入的帧)writePool BufferPool // 提供和管理写缓冲区的池writeBufSize int// 写缓冲区的大小writeDeadline time.Time // 写操作的截止时间writer io.WriteCloser // the current writer returned to the application(当前返回给应用程序的写入器)isWriting bool// for best-effort concurrent write detection(用于尽最大努力检测并发写操作)writeErrMu sync.Mutex // 用于保护写操作错误的互斥锁writeErr error// 保存写操作中发生的错误enableWriteCompression bool// 指示是否启用写操作压缩compressionLevel int// 写操作压缩的级别newCompressionWriter func(io.WriteCloser,int) io.WriteCloser // 用于创建新的压缩写入器// Read fields(读操作相关字段)reader io.ReadCloser // the current reader returned to the application (当前 返回给应用程序的读取器)readErr error// 保存读操作中发生的错误br *bufio.Reader // 带缓冲的读取器// bytes remaining in current frame. // set setReadRemaining to safely update this value and prevent overflowreadRemaining int64// 当前帧剩余的字节数readFinal bool// true the current message has more frames.(指示当前消息是否有更多帧)readLength int64// Message size. // 消息大小readLimit int64// Maximum message size. // 消息的最大大小readMaskPos int// 掩码在消息中的位置readMaskKey [4]byte// 用于WebSocket消息掩码handlePong func(string)error// 处理Pong帧的回调函数handlePing func(string)error// 处理Ping帧的回调函数handleClose func(int,string)error// 处理关闭帧的回调函数readErrCount int// 记录读取错误的次数messageReader *messageReader // the current low-level reader(当前的底层消息读取器)readDecompress bool// whether last read frame had RSV1 set(指示最后读取的帧是否设置了RSV1(用于压缩))newDecompressionReader func(io.Reader) io.ReadCloser // 用于创建新的解压缩读取器}
之后我们来看一个关键的函数ReadMessage
// ReadMessage is a helper method for getting a reader using NextReader and// reading from that reader to a buffer.func(c *Conn)ReadMessage()(messageType int, p []byte, err error){var r io.ReadermessageType, r, err = c.NextReader()if err !=nil{return messageType,nil, err}p, err = io.ReadAll(r)return messageType, p, err
}
// NextReader returns the next data message received from the peer. The// returned messageType is either TextMessage or BinaryMessage.//// There can be at most one open reader on a connection. NextReader discards// the previous message if the application has not already consumed it.//// Applications must break out of the application's read loop when this method// returns a non-nil error value. Errors returned from this method are// permanent. Once this method returns a non-nil error, all subsequent calls to// this method return the same error.func(c *Conn)NextReader()(messageType int, r io.Reader, err error){// Close previous reader, only relevant for decompression.if c.reader !=nil{_= c.reader.Close()c.reader =nil}c.messageReader =nilc.readLength =0for c.readErr ==nil{frameType, err := c.advanceFrame()if err !=nil{c.readErr = errbreak}if frameType == TextMessage || frameType == BinaryMessage {c.messageReader =&messageReader{c}c.reader = c.messageReaderif c.readDecompress {c.reader = c.newDecompressionReader(c.reader)}return frameType, c.reader,nil}}// Applications that do handle the error returned from this method spin in// tight loop on connection failure. To help application developers detect// this error, panic on repeated reads to the failed connection.c.readErrCount++if c.readErrCount >=1000{panic("repeated read on failed websocket connection")}return noFrame,nil, c.readErr
}
论文题目： ReLU Strikes Back: Exploiting Activation Sparsity in Large Language Models 论文链接： https://arxiv.org/abs/2310.04564 参数规模超过十亿（1B）的大型语言模型（LLM）已经彻底改变了现阶段人工…
对fill用法的介绍
1.用邻接矩阵实现
const int maxn100;
const int INF100000000;//无穷大，用来初始化边
int G[maxn][maxn];//用邻接矩阵存储图的信息
int isin[maxn]{false};//记录是否已被访问
int minDis[maxn];//记录到顶点的最小距离void Dijkstra(int s,in…
)
