{"id":327151,"date":"2022-01-10T08:46:49","date_gmt":"2022-01-10T08:46:49","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=327151"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=327151","title":{"rendered":"<span>IO_URING. \u0427\u0430\u0441\u0442\u044c 2. Let&#8217;s GO<\/span>"},"content":{"rendered":"<div><\/div>\n<div id=\"post-content-body\" class=\"article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w780q1\/getpro\/habr\/upload_files\/0ab\/4b9\/0ed\/0ab4b90ed2820ca548d324a5a9dbaf0a.jpg\" width=\"1366\" height=\"566\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/0ab\/4b9\/0ed\/0ab4b90ed2820ca548d324a5a9dbaf0a.jpg\" data-blurred=\"true\"\/><figcaption><\/figcaption><\/figure>\n<p>\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442! \u041f\u0440\u043e\u0434\u043e\u043b\u0436\u0430\u0435\u043c \u0440\u0430\u0437\u0431\u0438\u0440\u0430\u0442\u044c\u0441\u044f \u0441 io_uring. \u0421\u0435\u0433\u043e\u0434\u043d\u044f \u043f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c io_uring \u0434\u043b\u044f \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u043f\u0440\u0438\u043a\u043b\u0430\u0434\u043d\u044b\u0445 \u0437\u0430\u0434\u0430\u0447. \u0421\u043d\u0430\u0447\u0430\u043b\u0430 \u043c\u0438\u0433\u0440\u0438\u0440\u0443\u0435\u043c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0438\u0437 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0433\u043e \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u0430 \u0441 C \u043d\u0430 GO, \u0437\u0430\u0442\u0435\u043c \u043f\u043e\u0434\u0433\u043e\u0442\u043e\u0432\u0438\u043c \u043f\u043e\u0447\u0432\u0443 \u0434\u043b\u044f \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044f \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u044b\u0445 TCP \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u0432. \u041d\u0443 \u0438 \u0431\u0435\u0437 \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044f \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u043d\u0435 \u043e\u0431\u043e\u0439\u0434\u0435\u0442\u0441\u044f. \u041e\u0431\u043e\u0439\u0434\u0435\u043c\u0441\u044f \u0431\u0435\u0437 \u0434\u043b\u0438\u043d\u043d\u043e\u0433\u043e \u0432\u0441\u0442\u0443\u043f\u043b\u0435\u043d\u0438\u044f, \u0432\u043f\u0435\u0440\u0435\u0434 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c!<\/p>\n<hr\/>\n<h2>\u0414\u0438\u0441\u043a\u043b\u0435\u0439\u043c\u0435\u0440<\/h2>\n<p>\u042d\u0442\u043e \u0432\u0442\u043e\u0440\u0430\u044f \u0441\u0442\u0430\u0442\u044c\u044f \u0438\u0437 \u0441\u0435\u0440\u0438\u0438, \u043f\u043e\u0441\u0432\u044f\u0449\u0435\u043d\u043d\u043e\u0439 io_uring. \u0427\u0442\u043e\u0431\u044b \u043f\u043e\u043d\u0438\u043c\u0430\u0442\u044c, \u043e \u0447\u0435\u043c \u0440\u0435\u0447\u044c \u2014 \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u044c\u0442\u0435\u0441\u044c \u0441 <a href=\"https:\/\/habr.com\/ru\/company\/itsoft\/blog\/589389\/\">\u043f\u0435\u0440\u0432\u044b\u043c \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u043e\u043c<\/a>.\u00a0\u00a0<\/p>\n<p>\u0421\u0435\u0433\u043e\u0434\u043d\u044f \u043e\u0441\u0442\u0430\u0432\u0438\u043c \u0432 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u0442\u0435\u043e\u0440\u0438\u044e io_uring, \u043d\u043e c\u0444\u043e\u043a\u0443\u0441\u0438\u0440\u0443\u0435\u043c\u0441\u044f \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u0430\u0441\u043f\u0435\u043a\u0442\u0430\u0445 \u043f\u0440\u0438\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u044d\u0442\u043e\u0439 \u0442\u0435\u0445\u043d\u043e\u043b\u043e\u0433\u0438\u0438, \u0442\u0430\u043a \u0447\u0442\u043e \u043a\u043e\u0434\u0430 \u0431\u0443\u0434\u0435\u0442 \u043c\u043d\u043e\u0433\u043e. \u0414\u043b\u044f \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u043e\u0432 \u0431\u044b\u043b\u0430 \u0432\u044b\u0431\u0440\u0430\u043d\u0430 \u0440\u0430\u0431\u043e\u0442\u0430 \u0441 \u0441\u043e\u043a\u0435\u0442\u0430\u043c\u0438, \u0430 \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u044d\u0442\u0430\u043b\u043e\u043d\u0430 \u2014 runtime GO. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0432 \u044d\u0442\u043e\u043c \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u0435, \u043a\u043e\u0434 \u0431\u0443\u0434\u0435\u0442 \u043d\u0430 \u044f\u0437\u044b\u043a\u0435 GO, \u0434\u0430 \u0438 \u043f\u0440\u0438\u043c\u0435\u043d\u0435\u043d\u0438\u0435 io_uring \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0432 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0435 GO.<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0434\u0430\u043d\u043d\u0430\u044f \u0442\u0435\u043c\u0430 \u0431\u0443\u0434\u0435\u0442 \u043d\u0435\u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u0430, \u0442\u043e \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442\u0435 \u043a \u0441\u0442\u0430\u0442\u044c\u0435 \u043d\u043e\u043c\u0435\u0440 3. \u0422\u0430\u043c \u0441\u043d\u043e\u0432\u0430 \u0431\u0443\u0434\u0435\u0442 \u043e\u0431\u0441\u0443\u0436\u0434\u0435\u043d\u0438\u0435 \u0444\u0438\u0447 io_uring, \u043d\u0430\u0441\u0442\u0440\u043e\u0435\u043a \u0438 \u0440\u0435\u0436\u0438\u043c\u043e\u0432 \u0440\u0430\u0431\u043e\u0442\u044b, \u0442\u044e\u043d\u0438\u043d\u0433\u0430 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438.<\/p>\n<h2>Echo-\u0441\u0435\u0440\u0432\u0435\u0440, \u0442\u0443\u0448\u0451\u043d\u044b\u0439 \u0441 \u043f\u0440\u0438\u043f\u0440\u0430\u0432\u0430\u043c\u0438  <\/h2>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w780q1\/getpro\/habr\/upload_files\/e61\/53f\/697\/e6153f697000e6db0491953ba9e42f9a.jpg\" width=\"600\" height=\"570\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/e61\/53f\/697\/e6153f697000e6db0491953ba9e42f9a.jpg\" data-blurred=\"true\"\/><figcaption><\/figcaption><\/figure>\n<p>\u041f\u0440\u0435\u0436\u0434\u0435 \u0447\u0435\u043c \u0441\u043e\u043f\u0435\u0440\u043d\u0438\u0447\u0430\u0442\u044c \u0441 runtime&#8217;\u043e\u043c GO, \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u043f\u043e\u0433\u043e\u0432\u043e\u0440\u0438\u043c \u043e\u0431 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0435, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c. \u0414\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 io_uring \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0432\u043e\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0441\u0432\u044f\u0437\u043a\u043e\u0439 CGO + liburing, \u043d\u043e, \u0442\u0430\u043a \u043a\u0430\u043a \u043e\u0441\u043e\u0431\u044b\u0445 \u043f\u043e\u043c\u0435\u0445 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u043c\u0438 \u0432\u044b\u0437\u043e\u0432\u0430\u043c\u0438 \u0441\u0435\u043c\u0435\u0439\u0441\u0442\u0432\u0430 io_uring \u0432 GO \u043d\u0435\u0442 (\u043d\u0443 \u043b\u0430\u0434\u043d\u043e, \u043e\u043d\u0438 \u0435\u0441\u0442\u044c, \u043d\u043e \u0433\u043e\u0432\u043e\u0440\u0438\u0442\u044c \u0441\u0435\u0433\u043e\u0434\u043d\u044f \u043e \u043d\u0438\u0445 \u043d\u0435 \u0431\u0443\u0434\u0435\u043c), \u043f\u043e\u0447\u0435\u043c\u0443 \u0431\u044b \u043d\u0435 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043f\u043e\u043b\u043d\u043e\u0441\u0442\u044c\u044e \u043d\u0430\u0442\u0438\u0432\u043d\u0443\u044e \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0443? \u0414\u0430\u0432\u0430\u0439\u0442\u0435 \u043f\u0435\u0440\u0435\u043f\u0438\u0448\u0435\u043c echo-\u0441\u0435\u0440\u0432\u0435\u0440 \u0438\u0437 \u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0438 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 <a href=\"https:\/\/github.com\/godzie44\/go-uring\">go-uring<\/a>:<\/p>\n<details class=\"spoiler\">\n<summary>GO echo-server<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">package main  import ( \"errors\" \"flag\" \"fmt\" \"github.com\/godzie44\/go-uring\/uring\" \"log\" \"strconv\" \"syscall\" )  const MaxConns = 4096 const Backlog = 512 const MaxMsgLen = 2048  type connType int  const ( _ connType = iota ACCEPT READ WRITE )  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0431\u0443\u0434\u0435\u043c \u0434\u0435\u0440\u0436\u0430\u0442\u044c \u0432 \u043f\u0430\u043c\u044f\u0442\u0438 connInfo \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443. \/\/ fd \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0441\u043e\u043a\u0435\u0442\u0430. \/\/ typ - \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u043e\u043a\u0435\u0442 (\u043e\u0436\u0438\u0434\u0430\u0435\u0442 \u0447\u0442\u0435\u043d\u0438\u044f\/\u0437\u0430\u043f\u0438\u0441\u0438\/accept'\u0430). \/\/ sendOp, recvOp - \u0437\u0430\u043a\u0435\u0448\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0447\u0442\u0435\u043d\u0438\u044f \u0438\u0437 \u0441\u043e\u043a\u0435\u0442\u0430\/\u0437\u0430\u043f\u0438\u0441\u0438 \u0432 \u0441\u043e\u043a\u0435\u0442. type connInfo struct { fd  int typ connType  sendOp *uring.SendOp recvOp *uring.RecvOp }  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043f\u0440\u0435\u0434\u0430\u043b\u043e\u0446\u0438\u0440\u0443\u0435\u043c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0447\u0442\u0435\u043d\u0438\u044f \u0438 \u0437\u0430\u043f\u0438\u0441\u0438. \/\/ \u041f\u0435\u0440\u0435\u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044f \u0447\u0442\u0435\u043d\u0438\u044f \u0438 \u0437\u0430\u043f\u0438\u0441\u0438 \u0441\u043d\u0438\u0437\u0438\u0442 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0443 \u043d\u0430 GC. func makeConns() [MaxConns]connInfo { var conns [MaxConns]connInfo for fd := range conns { conns[fd].recvOp = uring.Recv(uintptr(fd), nil, 0) conns[fd].sendOp = uring.Send(uintptr(fd), nil, 0) } return conns }  \/\/ \u0411\u0443\u0444\u0435\u0440 \u0434\u043b\u044f \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439. var conns = makeConns()  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \u0431\u0443\u0444\u0435\u0440\u0430 \u0434\u043b\u044f \u0437\u0430\u043f\u0438\u0441\u0438\/\u0447\u0442\u0435\u043d\u0438\u044f. func makeBuffers() [][]byte { buffs := make([][]byte, MaxConns) for i := range buffs { buffs[i] = make([]byte, MaxMsgLen) } return buffs }  var buffs = makeBuffers()  func main() { flag.Parse() port, _ := strconv.Atoi(flag.Arg(0))    \/\/ \u0421\u043e\u0437\u0434\u0430\u0435\u043c \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u044b\u0439 \u0441\u043e\u043a\u0435\u0442 \u0438 \u0441\u043b\u0443\u0448\u0430\u0435\u043c \u043f\u043e\u0440\u0442.  \/\/ \u041e\u0442\u043c\u0435\u0442\u0438\u043c, \u0447\u0442\u043e \u043f\u0440\u0438 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0441\u043e\u043a\u0435\u0442\u0430 \u0444\u043b\u0430\u0433 O_NON_BLOCK \u043d\u0435 \u0443\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f, \/\/ \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u0432\u0441\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 read\/write \u0438 \u0442\u0434 \u043f\u0440\u0435\u043e\u0431\u0440\u0430\u0437\u0443\u044e\u0442\u0441\u044f \u0432 \u043d\u0435\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b \u0432\u043d\u0443\u0442\u0440\u0438 io_uring serverSockFd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, 0) checkErr(err) defer syscall.Close(serverSockFd)  checkErr(syscall.SetsockoptInt(serverSockFd, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1))  checkErr(syscall.Bind(serverSockFd, &amp;syscall.SockaddrInet4{ Port: port, })) checkErr(syscall.Listen(serverSockFd, Backlog))  fmt.Printf(\"io_uring echo server listening for connections on port: %d\\n\", port)  \/\/ \u0421\u043e\u0437\u0434\u0430\u0435\u043c \u044d\u043a\u0437\u0435\u043c\u043f\u043b\u044f\u0440 io_uring, \u043d\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c \u043d\u0438\u043a\u0430\u043a\u0438\u0435 \u043a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438. \/\/ \u0412\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c SQ\/SQ \u0431\u0443\u0444\u0435\u0440\u043e\u0432 \u0443\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u043c \u0432 4096 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432. ring, err := uring.New(4096) checkErr(err) defer ring.Close()  \/\/ \u041f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0444\u0438\u0447\u0438 IORING_FEAT_FAST_POLL.   \/\/ \u0414\u043b\u044f \u043d\u0430\u0441 \u044d\u0442\u043e \u043d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \"\u043f\u0435\u0440\u0444\u043e\u0440\u043c\u044f\u0449\u0430\u044f\" \u0444\u0438\u0447\u0430 \u0432 \u0434\u0430\u043d\u043d\u043e\u043c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438,   \/\/ \u0444\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u044d\u0442\u043e \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0439 \u0432 io_uring \u0434\u0432\u0438\u0436\u043e\u043a \u0434\u043b\u044f \u043f\u043e\u043b\u043b\u0438\u043d\u0433\u0430 I\/O. if !ring.Params.FastPollFeature() { checkErr(errors.New(\"IORING_FEAT_FAST_POLL not available\")) }  \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u043f\u0435\u0440\u0432\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 SQ - \u0441\u043b\u0443\u0448\u0430\u0435\u043c \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u044b\u0439 \u0441\u043e\u043a\u0435\u0442 \u043d\u0430 \u043f\u0440\u0435\u0434\u043c\u0435\u0442 \u043d\u043e\u0432\u044b\u0445 \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0445 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439. acceptOp := uring.Accept(uintptr(serverSockFd), 0) addAccept(ring, acceptOp)  cqes := make([]*uring.CQEvent, Backlog)  var cqe *uring.CQEvent for { \/\/ \u0421\u0430\u0431\u043c\u0438\u0442\u0438\u043c \u0432\u0441\u0435 SQE \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0431\u044b\u043b\u0438 \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u044b \u043d\u0430 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439 \u0438\u0442\u0435\u0440\u0430\u0446\u0438\u0438.. _, err = ring.Submit() checkErr(err)  \/\/ \u0416\u0434\u0435\u043c \u043a\u043e\u0433\u0434\u0430 \u0432 CQ \u0431\u0443\u0444\u0435\u0440\u0435 \u043f\u043e\u044f\u0432\u0438\u0442\u0441\u044f \u0445\u043e\u0442\u044f \u0431\u044b \u043e\u0434\u043d\u043e CQE. _, err = ring.WaitCQEvents(1) if errors.Is(err, syscall.EAGAIN) || errors.Is(err, syscall.EINTR) { continue } checkErr(err)  \/\/ \u041f\u043e\u043c\u0435\u0449\u0430\u0435\u043c \u0432\u0441\u0435 \"\u0433\u043e\u0442\u043e\u0432\u044b\u0435\" CQE \u0432 \u0431\u0443\u0444\u0435\u0440 cqes. n := ring.PeekCQEventBatch(cqes)  for i := 0; i &lt; n; i++ { cqe = cqes[i]        \/\/ \u0412 \u043f\u043e\u043b\u0435 user_data \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0438\u043d\u0434\u0435\u043a\u0441 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0435\u0433\u043e connInfo       \/\/ \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u043b\u0443\u0436\u0435\u0431\u043d\u0430\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f \u043f\u043e \u0441\u043e\u043a\u0435\u0442\u0443. ud := conns[cqe.UserData] typ := ud.typ res := cqe.Res  ring.SeenCQE(cqe)  \/\/ \u041f\u0440\u043e\u0432\u0435\u0440\u044f\u044f \u0442\u0438\u043f \u043c\u044b \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u0446\u0438\u0440\u0443\u0435\u043c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0432 CQE (accept \/ recv \/ send). switch typ { case ACCEPT: addRead(ring, int(res)) addAccept(ring, acceptOp) case READ: if res &lt;= 0 { _ = syscall.Shutdown(ud.fd, syscall.SHUT_RDWR) } else { addWrite(ring, ud.fd, res) } case WRITE: addRead(ring, ud.fd) } } } }  \/\/ addAccept - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ accept \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0441\u0435\u0440\u0432\u0435\u0440 \u0441\u043e\u043a\u0435\u0442\u0430. func addAccept(ring *uring.Ring, acceptOp *uring.AcceptOp) { conns[acceptOp.Fd()].fd = acceptOp.Fd() conns[acceptOp.Fd()].typ = ACCEPT  err := ring.QueueSQE(acceptOp, 0, uint64(acceptOp.Fd())) checkErr(err) }  \/\/ addRead - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ read \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430. func addRead(ring *uring.Ring, fd int) { buff := buffs[fd]  ci := &amp;conns[fd] ci.fd = fd ci.typ = READ ci.recvOp.SetBuffer(buff)  err := ring.QueueSQE(ci.recvOp, 0, uint64(fd)) checkErr(err) }  \/\/ addWrite - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ write \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430. func addWrite(ring *uring.Ring, fd int, bytesRead int32) { buff := buffs[fd]  ci := &amp;conns[fd] ci.fd = fd ci.typ = WRITE ci.sendOp.SetBuffer(buff[:bytesRead])  err := ring.QueueSQE(ci.sendOp, 0, uint64(fd)) checkErr(err) }  func checkErr(err error) { if err != nil { log.Fatal(err) } }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>\u041a\u043e\u0434 \u043d\u0430 GO \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0441\u044f \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043a\u043e\u043c\u043f\u0430\u043a\u0442\u043d\u0435\u0435 \u0447\u0435\u043c <a href=\"https:\/\/github.com\/frevib\/io_uring-echo-server\/blob\/master\/io_uring_echo_server.c\">\u044d\u0442\u043e\u0442 \u0436\u0435 \u0441\u0435\u0440\u0432\u0435\u0440<\/a> \u043d\u0430 plain C. \u0421 \u0434\u0440\u0443\u0433\u043e\u0439 \u0441\u0442\u043e\u0440\u043e\u043d\u044b, \u043e\u0431\u0430 \u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a\u0430 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0441\u0445\u043e\u0436\u0438 \u043a\u0430\u043a \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u0447\u0435\u0441\u043a\u0438, \u0442\u0430\u043a \u0438 \u0441\u0438\u043d\u0442\u0430\u043a\u0441\u0438\u0447\u0435\u0441\u043a\u0438. \u0410 \u0447\u0442\u043e \u043f\u043e \u043f\u043e\u0432\u043e\u0434\u0443 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438? \u0421 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u044b\u043c \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435\u043c \u043c\u0435\u0442\u043e\u0434\u0438\u043a\u0438 \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044f \u043c\u043e\u0436\u043d\u043e \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u0438\u0442\u044c\u0441\u044f <a href=\"https:\/\/github.com\/godzie44\/go-uring\/blob\/master\/example\/echo-server\/benchmark.md\">\u0437\u0434\u0435\u0441\u044c<\/a>. \u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0438\u0441\u043a\u043b\u044e\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b:<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>c: 100    bytes: 128<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>c: 50     bytes: 1024<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>c: 500  bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 500 bytes: 1024<\/p>\n<\/td>\n<td>\n<p>c: 1000 bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 1000 bytes: 1024<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<p>io_uring-echo-server (C lang)<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>235356<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>224783<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>173670<\/p>\n<\/td>\n<td>\n<p>155477<\/p>\n<\/td>\n<td>\n<p>149407<\/p>\n<\/td>\n<td>\n<p>139987<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<p>echo-server<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>227884<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>222709<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>169001<\/p>\n<\/td>\n<td>\n<p>150275<\/p>\n<\/td>\n<td>\n<p>143664<\/p>\n<\/td>\n<td>\n<p>128783<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>\u041e\u0442\u043b\u0438\u0447\u043d\u043e! GO-\u043a\u043e\u0434 \u043d\u0435 \u0441\u0438\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0438\u0433\u0440\u044b\u0432\u0430\u0435\u0442 \u043a\u043e\u0434\u0443 \u043d\u0430 C \u0432 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0435 I\/O \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438. \u041d\u043e, \u0435\u0441\u0442\u044c \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430, \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0442\u0440\u0430\u043d\u0441\u043f\u043e\u0440\u0442\u043d\u043e\u0433\u043e \u0441\u043b\u043e\u044f \u043f\u0440\u0438\u0431\u0438\u0442\u0430 \u0433\u0432\u043e\u0437\u0434\u044f\u043c\u0438 \u043a \u043b\u043e\u0433\u0438\u043a\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f, \u0447\u0442\u043e \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0435\u0435 \u0433\u0434\u0435-\u043b\u0438\u0431\u043e \u043a\u0440\u043e\u043c\u0435 \u043a\u0430\u043a \u0432 echo-\u0441\u0435\u0440\u0432\u0435\u0440\u0435. \u0414\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u043f\u0438\u0441\u0430\u0442\u044c \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u044b\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0441 io_uring \u0432 GO, \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u044b \u0438\u0437 \u043f\u0430\u043a\u0435\u0442\u0430 net: net.Conn \u0438 net.Listener. \u0410 \u0434\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u043d\u0443\u0436\u043d\u043e \u0440\u0430\u0437\u043e\u0431\u0440\u0430\u0442\u044c\u0441\u044f \u0432 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u0445 net.Conn \u0438 net.Listener \u0434\u043b\u044f \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 TCP \u0438 \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438. \u041d\u043e \u043e\u0431\u043e \u0432\u0441\u0435\u043c \u043f\u043e \u043f\u043e\u0440\u044f\u0434\u043a\u0443.  <\/p>\n<h3>\u0412 \u043b\u043e\u0433\u043e\u0432\u0435 net package<\/h3>\n<p>\u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u044b\u0435 \u043d\u0430\u043c \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u044b \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435.<\/p>\n<h4>net.Listener<\/h4>\n<p>\u0417\u0430\u0434\u0430\u0447\u0430 listener&#8217;\u0430 \u2014 \u0441\u043b\u0443\u0448\u0430\u0442\u044c \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u043f\u043e\u0440\u0442 \u0438 \u043f\u0440\u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043a \u0441\u0435\u0440\u0432\u0435\u0440\u0443 \u043e\u0447\u0435\u0440\u0435\u0434\u043d\u043e\u0433\u043e \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0443\u044e net.Conn, \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u044d\u0442\u0438\u043c \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u043c. \u0421\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441:<\/p>\n<pre><code class=\"go\">\/\/ A Listener is a generic network listener for stream-oriented protocols. \/\/ \/\/ Multiple goroutines may invoke methods on a Listener simultaneously. type Listener interface { \/\/ Accept waits for and returns the next connection to the listener. Accept() (Conn, error)  \/\/ Close closes the listener. \/\/ Any blocked Accept operations will be unblocked and return errors. Close() error  \/\/ Addr returns the listener's network address. Addr() Addr }<\/code><\/pre>\n<h4>net.Conn<\/h4>\n<p>net.Conn &#8212; \u0430\u0431\u0441\u0442\u0440\u0430\u043a\u0446\u0438\u044f \u043d\u0430\u0434 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435\u043c, \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0442\u044c \u0447\u0442\u0435\u043d\u0438\u0435 \u0438 \u0437\u0430\u043f\u0438\u0441\u044c \u0432 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0439 \u0441\u043e\u043a\u0435\u0442. \u0418\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 (\u0434\u043b\u044f \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u0430 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0443\u043f\u0440\u043e\u0449\u0435\u043d):<\/p>\n<pre><code class=\"go\">type Conn interface{ \/\/ Read reads data from the connection. Read(b []byte) (n int, err error)  \/\/ Write writes data to the connection. Write(b []byte) (n int, err error)  \/\/ Close closes the connection. Close() error }<\/code><\/pre>\n<p>\u0421\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u044d\u0442\u0438\u0445 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u043e\u0432 \u043b\u0435\u0436\u0430\u0442 \u0432 \u043e\u0441\u043d\u043e\u0432\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0442\u0440\u0430\u043d\u0441\u043f\u043e\u0440\u0442\u043d\u043e\u0433\u043e \u0443\u0440\u043e\u0432\u043d\u044f \u0432 GO. \u0418\u043c\u0435\u044f \u043d\u0430 \u0440\u0443\u043a\u0430\u0445 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 net.Listner \u0438 net.Conn \u0434\u043b\u044f, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, TCP \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 \u043c\u043e\u0436\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043b\u044e\u0431\u043e\u0439 \u0432\u044b\u0448\u0435\u0441\u0442\u043e\u044f\u0449\u0438\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b, \u0431\u0443\u0434\u044c \u0442\u043e HTTP \u0438\u043b\u0438 \u043b\u044e\u0431\u043e\u0439 \u0434\u0440\u0443\u0433\u043e\u0439. \u041a \u043f\u0440\u0438\u043c\u0435\u0440\u0443, \u0432\u043e\u0442 \u0442\u0430\u043a\u00a0\u0431\u0443\u0434\u0435\u0442 \u0432\u044b\u0433\u043b\u044f\u0434\u0435\u0442\u044c echo-server \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u0445 net.TCPListener \u0438 net.TCPConn:<\/p>\n<details class=\"spoiler\">\n<summary>\u043e\u0431\u044b\u0447\u043d\u044b\u0439 echo-server<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">package main  import ( \"io\" \"log\" \"net\" )  const MaxConns = 4096 const MaxMsgLen = 2048  func initBuffs() [][]byte { buffs := make([][]byte, MaxConns) for i := range buffs { buffs[i] = make([]byte, MaxMsgLen) } return buffs }  var buffs = initBuffs()  func main() { listener, err := net.ListenTCP(\"tcp\", &amp;net.TCPAddr{ Port: 8080, }) checkErr(err)  for { conn, err := listener.Accept() checkErr(err)  go handleConn(conn) } }  func handleConn(conn net.Conn) { f, _ := conn.(*net.TCPConn).File() buff := buffs[int(f.Fd())] for { n, err := conn.Read(buff) if err == io.EOF || n == 0 { checkErr(conn.Close()) return } checkErr(err)  _, err = conn.Write(buff[:n]) checkErr(err) } }  func checkErr(err error) { if err != nil { log.Fatal(err) } }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>\u0412\u0441\u0435 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e, \u0432 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e\u043c \u0446\u0438\u043a\u043b\u0435 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0435\u043c \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0435 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0430 \u0437\u0430\u0442\u0435\u043c, \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0443 \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u043c \u0447\u0438\u0442\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0438\u0437 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430 \u0438 \u043f\u0438\u0441\u0430\u0442\u044c \u0442\u0443\u0434\u0430 \u0436\u0435. \u041d\u043e \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u044c\u0442\u0435, \u0447\u0442\u043e \u043a\u0430\u043a\u043e\u0439-\u0442\u043e \u0438\u0437 \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u0432 \u0440\u0435\u0448\u0438\u043b \u043d\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u043d\u0430\u043c \u0434\u0430\u043d\u043d\u044b\u0435, \u043a \u043f\u0440\u0438\u043c\u0435\u0440\u0443, \u0432 \u0442\u0435\u0447\u0435\u043d\u0438\u0435 \u043c\u0438\u043d\u0443\u0442\u044b. \u0412 \u0442\u0430\u043a\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043f\u043e\u0442\u043e\u043a, \u043d\u0430 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e\u0449\u0430\u044f \u0447\u0442\u0435\u043d\u0438\u0435, \u0437\u0430\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u0435\u0442\u0441\u044f? \u0415\u0441\u0442\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u043d\u0435\u0442! \u041b\u044e\u0431\u043e\u0439 GO \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u0437\u043d\u0430\u0435\u0442 \u2014 \u044d\u0442\u043e \u043d\u0435 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430. \u041d\u043e \u043a\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u043a\u0430\u0437\u0430\u043b\u043e\u0441\u044c \u0431\u044b, \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0435 \u0432\u044b\u0437\u043e\u0432\u044b <em>conn.Read<\/em> \u043d\u0435 \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0442 \u043f\u043e\u0442\u043e\u043a \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f? \u0418 \u0442\u0443\u0442 \u0432 \u0434\u0435\u043b\u043e \u0432\u0441\u0442\u0443\u043f\u0430\u0435\u0442 runtime, \u0432\u0435\u0440\u043d\u0435\u0435 \u0435\u0433\u043e \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442 \u2014 netpoller.<\/p>\n<h2>netpoller &#8212; \u0442\u0440\u043e\u043f\u0430 \u0447\u0435\u0440\u0435\u0437 block I\/O<\/h2>\n<p>\u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043a\u0430\u043a \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0442 \u0441 I\/O \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044f\u043c\u0438 \u043d\u0430\u0434 \u0441\u043e\u043a\u0435\u0442\u0430\u043c\u0438 \u043d\u0430 \u043f\u0440\u0438\u043c\u0435\u0440\u0435 \u0447\u0442\u0435\u043d\u0438\u044f. \u0412 GO \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 (<em>G<\/em>) \u0436\u0435\u043b\u0430\u044e\u0449\u0430\u044f \u043f\u0440\u043e\u0447\u0438\u0442\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0438\u0437 \u0441\u043e\u043a\u0435\u0442\u0430, \u0441\u043d\u0430\u0447\u0430\u043b\u0430 \u043f\u043e\u043f\u044b\u0442\u0430\u0435\u0442\u0441\u044f \u0432\u044b\u043f\u043e\u043b\u043d\u0438\u0442\u044c \u0447\u0442\u0435\u043d\u0438\u0435 \u0432 \u043d\u0435\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0435\u043c \u0440\u0435\u0436\u0438\u043c\u0435. \u0415\u0441\u043b\u0438 \u0447\u0442\u0435\u043d\u0438\u0435 \u0432 \u043d\u0430\u0441\u0442\u043e\u044f\u0449\u0438\u0439 \u043c\u043e\u043c\u0435\u043d\u0442 \u043d\u0435\u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e (\u043a \u043f\u0440\u0438\u043c\u0435\u0440\u0443, \u0432 \u0441\u043e\u043a\u0435\u0442\u0435 \u043d\u0435\u0442 \u0434\u0430\u043d\u043d\u044b\u0445) \u2014 <em>G<\/em> \u0431\u0443\u0434\u0435\u0442 \u0437\u0430\u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u0430\u043d\u0430. \u041f\u0440\u0438 \u044d\u0442\u043e\u043c \u043f\u043e\u0442\u043e\u043a \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f (<em>M<\/em>) \u043d\u0435 \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u0435\u0442\u0441\u044f,\u00a0\u0430 <em>G<\/em> \u0438\u043d\u0438\u0446\u0438\u0438\u0440\u0443\u044e\u0449\u0430\u044f \u0447\u0442\u0435\u043d\u0438\u0435 \u0443\u0445\u043e\u0434\u0438\u0442 \u0432 \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u0441\u043d\u0430. \u0415\u0435 \u043c\u0435\u0441\u0442\u043e \u043d\u0430 \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u043c \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0440\u0435 (<em>P<\/em>) \u0437\u0430\u0439\u043c\u0435\u0442 \u0434\u0440\u0443\u0433\u0430\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430. \u041d\u0430\u043a\u043e\u043d\u0435\u0446, \u043a\u043e\u0433\u0434\u0430 \u0441\u043e\u043a\u0435\u0442 \u0431\u0443\u0434\u0435\u0442 \u0433\u043e\u0442\u043e\u0432 \u0434\u043b\u044f I\/O (\u0432 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043f\u043e\u044f\u0432\u0438\u043b\u0438\u0441\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0434\u043b\u044f \u0447\u0442\u0435\u043d\u0438\u044f) &#8212; \u043f\u043b\u0430\u043d\u0438\u0440\u043e\u0432\u0449\u0438\u043a \u0440\u0430\u0437\u0431\u0443\u0434\u0438\u0442 <em>G<\/em>, \u0438 \u043d\u0430\u0448\u0430 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u0438\u0442 \u0437\u0430\u043f\u043b\u0430\u043d\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u0439 \u0432\u044b\u0437\u043e\u0432. <\/p>\n<p>\u0414\u043b\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u043f\u043e\u0434\u043e\u0431\u043d\u043e\u0433\u043e \u043c\u0435\u0445\u0430\u043d\u0438\u0437\u043c\u0430 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439:  <\/p>\n<ul>\n<li>\n<p>\u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 <em>G<\/em> \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u0441\u0435\u0431\u044f \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u0434\u043b\u044f \u043e\u043f\u043e\u0432\u0435\u0449\u0435\u043d\u0438\u044f \u043e \u0433\u043e\u0442\u043e\u0432\u043d\u043e\u0441\u0442\u0438 I\/O<\/p>\n<\/li>\n<li>\n<p>\u0431\u0443\u0434\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d \u043f\u043b\u0430\u043d\u0438\u0440\u043e\u0432\u0449\u0438\u043a\u043e\u043c, \u0447\u0442\u043e\u0431\u044b \u043f\u043e\u043d\u044f\u0442\u044c, \u043a\u0430\u043a\u0438\u043c <em>G<\/em> \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0440\u043d\u043e\u0435 \u0432\u0440\u0435\u043c\u044f \u0432 \u0441\u0432\u044f\u0437\u0438 \u0441 \u043f\u043e\u044f\u0432\u043b\u0435\u043d\u0438\u0435\u043c I\/O events<\/p>\n<\/li>\n<\/ul>\n<p>\u042d\u0442\u043e\u0442 \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442 runtime&#8217;\u0430 \u043d\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f netpoller \u0438 \u0432 \u0442\u043e\u043c \u0447\u0438\u0441\u043b\u0435, \u0431\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f \u0435\u043c\u0443, \u0441\u0435\u0440\u0432\u0435\u0440\u0430, \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u043d\u044b\u0435 \u043d\u0430 GO, \u043e\u0431\u043b\u0430\u0434\u0430\u044e\u0442 \u0442\u0430\u043a\u043e\u0439 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c\u044e.<\/p>\n<p>\u0410 \u0432\u043e\u0442 \u0435\u0433\u043e \u0443\u043f\u0440\u043e\u0449\u0435\u043d\u043d\u044b\u0439 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0430\u0441 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u0443\u0435\u0442:<\/p>\n<pre><code class=\"go\">func poll_runtime_pollWait(pd *pollDesc, mode int) int func netpoll(delay int64) gList<\/code><\/pre>\n<ul>\n<li>\n<p>poll_runtime_pollWait &#8212;\u00a0 \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0434\u043b\u044f <em>G<\/em> \u043f\u043e\u0434\u043f\u0438\u0441\u0430\u0442\u044c\u0441\u044f \u043d\u0430 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u0443\u044e\u0449\u0435\u0435 I\/O \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u0432 \u0441\u043e\u043a\u0435\u0442\u0435. \u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 pollDesc \u043e\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442 \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0441\u043e\u043a\u0435\u0442\u0430, \u0430 mode &#8212; \u0442\u0438\u043f \u0441\u043e\u0431\u044b\u0442\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u043e\u0433\u043e \u0441\u043b\u0435\u0434\u0443\u0435\u0442 \u0436\u0434\u0430\u0442\u044c (read\/write)<\/p>\n<\/li>\n<li>\n<p>netpoll &#8212; \u044d\u0442\u0430 \u0444\u0443\u043d\u043a\u0446\u0438\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u043b\u0430\u043d\u0438\u0440\u043e\u0432\u0449\u0438\u043a\u043e\u043c \u0434\u043b\u044f \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u044f \u0441\u043f\u0438\u0441\u043a\u0430 <em>G<\/em> \u043a\u043e\u0442\u043e\u0440\u044b\u043c \u043d\u0443\u0436\u043d\u043e \u0434\u0430\u0442\u044c \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0440\u043d\u043e\u0435 \u0432\u0440\u0435\u043c\u044f<\/p>\n<\/li>\n<\/ul>\n<p>\u0420\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f netpoller \u0437\u0430\u0432\u0438\u0441\u0438\u0442 \u043e\u0442 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 OS. \u0412 Linux netpoller \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u0441\u0435\u043c\u0435\u0439\u0441\u0442\u0432\u0430 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u0445 \u0432\u044b\u0437\u043e\u0432\u043e\u0432 epoll. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0432 GO \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u0430\u0442\u0442\u0435\u0440\u043d \u043f\u043e\u0434\u043f\u0438\u0441\u043a\u0438 \u043d\u0430 I\/O \u0441\u043e\u0431\u044b\u0442\u0438\u044f:<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w780q1\/getpro\/habr\/upload_files\/aa7\/cc7\/888\/aa7cc78883433379a8d7d11e59d0c709.jpg\" alt=\"\u0442\u0430\u043a \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u043e\u0431\u0449\u0430\u0435\u0442\u0441\u044f \u0441 netpoller'\u043e\u043c\" title=\"\u0442\u0430\u043a \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u043e\u0431\u0449\u0430\u0435\u0442\u0441\u044f \u0441 netpoller'\u043e\u043c\" width=\"2319\" height=\"2118\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/aa7\/cc7\/888\/aa7cc78883433379a8d7d11e59d0c709.jpg\" data-blurred=\"true\"\/><figcaption>\u0442\u0430\u043a \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u043e\u0431\u0449\u0430\u0435\u0442\u0441\u044f \u0441 netpoller&#8217;\u043e\u043c<\/figcaption><\/figure>\n<p>\u0418\u0442\u0430\u043a, \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e netpoller&#8217;\u0430 \u043c\u043e\u0436\u043d\u043e \u0434\u0435\u043b\u0430\u0442\u044c \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b, \u043d\u0435 \u0431\u043e\u044f\u0441\u044c \u0437\u0430\u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435. \u0412 \u0441\u0432\u043e\u044e \u043e\u0447\u0435\u0440\u0435\u0434\u044c, \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e io_uring \u043c\u043e\u0436\u043d\u043e \u0434\u043e\u0431\u0438\u0442\u044c\u0441\u044f \u0442\u0435\u0445 \u0436\u0435 \u0446\u0435\u043b\u0435\u0439, \u043d\u043e \u0434\u0440\u0443\u0433\u0438\u043c\u0438 \u0441\u0440\u0435\u0434\u0441\u0442\u0432\u0430\u043c\u0438. \u041a\u043e\u043d\u0446\u0435\u043f\u0446\u0438\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u043e\u0442\u0445\u043e\u0434\u0438\u0442 \u0432 \u0441\u0442\u043e\u0440\u043e\u043d\u0443, \u0432\u0435\u0434\u044c \u0441 io_uring \u043c\u043e\u0436\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e \u043f\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043d\u0430 \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u0438 \u043f\u043e\u0437\u0434\u043d\u0435\u0435 \u0443\u0437\u043d\u0430\u0442\u044c \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438.<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w780q1\/getpro\/habr\/upload_files\/4f0\/cd2\/f60\/4f0cd2f60ad174f123ae2a3aae59d5f4.jpg\" alt=\"\u0430 \u0442\u0430\u043a \u043c\u043e\u0433\u043b\u0430 \u0431\u044b \u043e\u0449\u0430\u0442\u044c\u0441\u044f \u0441 io_uring\" title=\"\u0430 \u0442\u0430\u043a \u043c\u043e\u0433\u043b\u0430 \u0431\u044b \u043e\u0449\u0430\u0442\u044c\u0441\u044f \u0441 io_uring\" width=\"3508\" height=\"2480\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/4f0\/cd2\/f60\/4f0cd2f60ad174f123ae2a3aae59d5f4.jpg\" data-blurred=\"true\"\/><figcaption>\u0430 \u0442\u0430\u043a \u043c\u043e\u0433\u043b\u0430 \u0431\u044b \u043e\u0449\u0430\u0442\u044c\u0441\u044f \u0441 io_uring<\/figcaption><\/figure>\n<p>\u0422\u0443\u0442 \u043d\u0443\u0436\u043d\u043e \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0440\u0435\u043c\u0430\u0440\u043a\u0443: \u043c\u043e\u0436\u043d\u043e \u0442\u043e\u0447\u043d\u043e \u0442\u0430\u043a \u0436\u0435 \u043e\u0442\u043b\u0430\u0432\u043b\u0438\u0432\u0430\u0442\u044c I\/O \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0438 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e io_uring \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 IORING_OP_POLL_ADD, \u043f\u0440\u0430\u0432\u0434\u0430, \u043d\u0430 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u0442\u0430\u043a\u043e\u0439 \u043f\u043e\u0434\u0445\u043e\u0434 \u043e\u0442\u0440\u0430\u0436\u0430\u0435\u0442\u0441\u044f \u0441\u043a\u043e\u0440\u0435\u0435 \u0432 \u043d\u0435\u0433\u0430\u0442\u0438\u0432\u043d\u0443\u044e \u0441\u0442\u043e\u0440\u043e\u043d\u0443.<\/p>\n<h2>\u041f\u0440\u0438\u0440\u0443\u0447\u0435\u043d\u0438\u0435 reactor<\/h2>\n<p>\u041d\u0443 \u0447\u0442\u043e \u0436\u0435, \u0442\u0435\u043f\u0435\u0440\u044c \u043c\u043e\u0436\u043d\u043e \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u043e\u043d\u043a\u0443\u0440\u0435\u043d\u0442\u0430 netpoller&#8217;\u0443 \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c io_uring. \u041d\u0430\u0437\u043e\u0432\u0435\u043c \u0435\u0433\u043e reactor. \u0421\u0443\u0442\u044c \u0438\u0434\u0435\u0438 \u043f\u0440\u043e\u0441\u0442\u0430, \u0440\u0435\u0430\u043a\u0442\u043e\u0440 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0435\u0442 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u043c\u044b\u0435 io_uring \u0438 \u0434\u0435\u0440\u0433\u0430\u0435\u0442 callback \u0432 userspace \u043f\u043e \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044e \u0442\u043e\u0439 \u0438\u043b\u0438 \u0438\u043d\u043e\u0439 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c,\u00a0reactor \u0431\u0443\u0434\u0435\u0442 \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u044b\u043c \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u043c I\/O \u0431\u044d\u043a\u0435\u043d\u0434\u043e\u043c. \u0412\u043e\u0442 \u0435\u0433\u043e \u043d\u0430\u0438\u0432\u043d\u0430\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f:<\/p>\n<details class=\"spoiler\">\n<summary>reactor.go<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">type Callback func(event uring.CQEvent)  type Reactor struct { ring *uring.Ring callbacks     map[uint64]Callback callbacksLock sync.Mutex queueSQELock sync.Mutex currentNonce uint64 submitSignal chan struct{} }  func New(ring *uring.Ring) *Reactor { return &amp;Reactor{ ring:         ring, submitSignal: make(chan struct{}), callbacks:    map[uint64]Callback{}, } }  func (r *Reactor) Run(ctx context.Context) { wg := &amp;sync.WaitGroup{}  \/\/\u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c \u0434\u0432\u0430 \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u0430 \u0440\u0435\u0430\u043a\u0442\u043e\u0440\u0430 \/\/consumer - \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442 \u043d\u043e\u0432\u044b\u0435 CQE \/\/publisher - \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u043d\u043e\u0432\u044b\u0435 SQE \u043d\u0430 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0443 wg.Add(2) go func() { defer wg.Done() r.runConsumer(ctx) }() go func() { defer wg.Done() r.runPublisher(ctx) }() wg.Wait() }  \/\/ \u0441\u0430\u0431\u043c\u0438\u0442\u0438\u043c \u043d\u043e\u0432\u044b\u0435 SQE \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0435 func (r *Reactor) runPublisher(ctx context.Context) { defer close(r.submitSignal) for { select { \/\/\u043f\u0440\u0438 \u043f\u043e\u0441\u0442\u0443\u043f\u043b\u0435\u043d\u0438\u0438 \u0441\u0438\u0433\u043d\u0430\u043b\u0430 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u043d\u043e\u0432\u044b\u0435 SQE case &lt;-r.submitSignal: r.queueSQELock.Lock() _, err := r.ring.Submit() r.queueSQELock.Unlock() if err != nil { log.Println(\"io_uring submit\", err) } case &lt;-ctx.Done(): return } } }  \/\/ \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f \u043a\u043e\u043c\u0430\u043d\u0434 \u0438 \u0434\u0435\u0440\u0433\u0430\u0435\u043c \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0435 \u043a\u043e\u043b\u0431\u0435\u043a\u0438 func (r *Reactor) runConsumer(ctx context.Context) { cqeBuff := make([]*uring.CQEvent, 512) \/\/ \u0446\u0438\u043a\u043b \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u0432 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439 (CQE) for { \/\/ \u043a\u043e\u043c\u0430\u043d\u0434\u0443\u0435\u043c Publisher'\u0443 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u043d\u043e\u0432\u044b\u0435 SQE r.submitSignal &lt;- struct{}{}  \/\/ \u0436\u0434\u0435\u043c \u0445\u043e\u0442\u044f\u0431\u044b \u043e\u0434\u043d\u0443 \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u043d\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e _, err := r.ring.WaitCQEventsWithTimeout(1, time.Millisecond) if errors.Is(err, syscall.EAGAIN) || errors.Is(err, syscall.EINTR) || errors.Is(err, syscall.ETIME) { runtime.Gosched() goto CheckCtxAndContinue }  if err != nil { log.Println(\"io_uring wait\", err) goto CheckCtxAndContinue }  for n := r.ring.PeekCQEventBatch(cqeBuff); n > 0; n = r.ring.PeekCQEventBatch(cqeBuff) { for i := 0; i &lt; n; i++ { cqe := cqeBuff[i]  nonce := cqe.UserData  \/\/\u043d\u0430\u0445\u043e\u0434\u0438\u043c \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 callback r.callbacksLock.Lock() cb := r.callbacks[nonce] delete(r.callbacks, nonce) r.callbacksLock.Unlock()  cb(uring.CQEvent{ UserData: cqe.UserData, Res:      cqe.Res, Flags:    cqe.Flags, }) }  \/\/\u0441\u043e\u043e\u0431\u0449\u0430\u0435\u043c io_uring \u043e N \u043f\u0440\u043e\u0441\u043c\u043e\u0442\u0440\u0435\u043d\u043d\u044b\u0445 CQE r.ring.AdvanceCQ(uint32(n)) }  CheckCtxAndContinue: select { case &lt;-ctx.Done(): return default: continue } } }  \/\/Queue \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 SQ. func (r *Reactor) Queue(op uring.Operation, cb Callback) (uint64, error) { \/\/\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u043c \u0443\u043d\u0438\u043a\u0430\u043b\u044c\u043d\u043e\u0435 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 UserData nonce := r.nextNonce()  r.queueSQELock.Lock() defer r.queueSQELock.Unlock()  \/\/\u043f\u043e\u043c\u0435\u0449\u0430\u0435\u043c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 SQ err := r.ring.QueueSQE(op, 0, nonce) if err == nil { r.callbacksLock.Lock() r.callbacks[nonce] = cb r.callbacksLock.Unlock() }  return nonce, err }  func (r *Reactor) nextNonce() uint64 { return atomic.AddUint64(&amp;r.currentNonce, 1) }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>C \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043f\u043e\u0434\u043e\u0431\u043d\u043e\u0433\u043e \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u0430 \u043c\u043e\u0436\u043d\u043e \u0434\u043e\u0431\u0430\u0432\u0438\u0442\u044c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 SQ \u043e\u0447\u0435\u0440\u0435\u0434\u044c io_uring \u0438 \u0440\u0435\u0430\u043a\u0442\u0438\u0432\u043d\u043e \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u044d\u0442\u043e\u0439 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438. \u0412\u043d\u0443\u0442\u0440\u0438 \u043f\u0430\u0440\u0430\u043b\u043b\u0435\u043b\u044c\u043d\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0442 consumer \u0434\u043b\u044f \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439 \u0432 SQ \u0438 publisher \u0434\u043b\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u043e\u0432 \u0438\u0437 CQ.\u00a0<br \/> \u00a0<br \/>\u0422\u0435\u043f\u0435\u0440\u044c, \u043f\u0440\u0438 \u043f\u043e\u043c\u043e\u0449\u0438 reactor&#8217;\u0430, \u043c\u043e\u0436\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0437\u0430\u0432\u0435\u0442\u043d\u044b\u0435 net.Listener \u0438 net.Conn \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u044b.<\/p>\n<details class=\"spoiler\">\n<summary>net.Listener. \u0420\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c reactor (\u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u0435 \u0443\u0447\u0430\u0441\u0442\u043a\u0438 \u043a\u043e\u0434\u0430 \u0432\u044b\u0431\u0440\u043e\u0448\u0435\u043d\u044b, \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043f\u043e\u043b\u043d\u0443\u044e \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044e \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435)<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">type Listener struct { fd         int reactor    *Reactor acceptChan chan uring.CQEvent addr       net.Addr }  func NewListener(addr string, reactor *Reactor) (*Listener, error) { tcpAddr, err := net.ResolveTCPAddr(\"tcp\", addr) if err != nil { return nil, err }  \/\/ serverSocket - \u0441\u043e\u0437\u0434\u0430\u0435\u0442 \u0438 \u0431\u0438\u043d\u0434\u0438\u0442 \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u044b\u0439 \u0441\u043e\u043a\u0435\u0442 sockFd, err := serverSocket(tcpAddr) if err != nil { return nil, err }  return &amp;Listener{ fd:         sockFd, addr:       tcpAddr, reactor:    reactor, acceptChan: make(chan uring.CQEvent), }, nil }  func (l *Listener) Accept() (net.Conn, error) { \/\/\u043f\u043e\u043c\u0435\u0449\u0430\u0435\u043c accept \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 \u0440\u0435\u0430\u043a\u0442\u043e\u0440 op := uring.Accept(uintptr(l.fd), 0) l.reactor.Queue(op, func(event uring.CQEvent) { l.acceptChan &lt;- event }) \/\/ \u0436\u0434\u0435\u043c \u043f\u043e\u044f\u0432\u043b\u0435\u043d\u0438\u0435 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f cqe := &lt;-l.acceptChan  if err := cqe.Error(); err != nil { return nil, err }  fd := int(cqe.Res) rAddr, _ := op.Addr() tc := newConn(fd, l.addr, rAddr, l.reactor) return tc, nil }<\/code><\/pre>\n<\/div>\n<\/details>\n<details class=\"spoiler\">\n<summary>net.Conn. \u0420\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c reactor (\u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u0435 \u0443\u0447\u0430\u0441\u0442\u043a\u0438 \u043a\u043e\u0434\u0430 \u0432\u044b\u0431\u0440\u043e\u0448\u0435\u043d\u044b, \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043f\u043e\u043b\u043d\u0443\u044e \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044e \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435)<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">type Conn struct { Fd                  int lAddr, rAddr        net.Addr reactor             *Reactor readChan, writeChan chan uring.CQEvent readLock, writeLock sync.Mutex }  func newConn(fd int, lAddr, rAddr net.Addr, r *Reactor) *Conn { return &amp;Conn{ lAddr:     lAddr, rAddr:     rAddr, Fd:        fd, reactor:   r, readChan:  make(chan uring.CQEvent), writeChan: make(chan uring.CQEvent), } }  func (c *Conn) Read(b []byte) (n int, err error) { c.readLock.Lock() defer c.readLock.Unlock()  \/\/\u043f\u043e\u043c\u0435\u0449\u0430\u0435\u043c Recv \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 \u0440\u0435\u0430\u043a\u0442\u043e\u0440 op := uring.Recv(uintptr(c.Fd), b, 0) c.reactor.Queue(op, func(event uring.CQEvent) { c.readChan &lt;- event }) \/\/\u0436\u0434\u0435\u043c \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u0447\u0442\u0435\u043d\u0438\u044f \u0438\u0437 \u0441\u043e\u043a\u0435\u0442\u0430 cqe := &lt;-c.readChan  if err = cqe.Error(); err != nil { return 0, &amp;net.OpError{Op: \"read\", Net: \"tcp\", Source: c.lAddr, Addr: c.rAddr, Err: err} } if cqe.Res == 0 { err = &amp;net.OpError{Op: \"read\", Net: \"tcp\", Source: c.lAddr, Addr: c.rAddr, Err: io.EOF} }  runtime.KeepAlive(b) return int(cqe.Res), err }  func (c *Conn) Write(b []byte) (n int, err error) { c.writeLock.Lock() defer c.writeLock.Unlock()  \/\/\u043f\u043e\u043c\u0435\u0449\u0430\u0435\u043c Send \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 \u0440\u0435\u0430\u043a\u0442\u043e\u0440 op := uring.Send(uintptr(c.Fd), b, 0) c.reactor.Queue(op, func(event uring.CQEvent) { c.writeChan &lt;- event }) \/\/\u0436\u0434\u0435\u043c \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u044f \u0437\u0430\u043f\u0438\u0441\u0438 \u0432 \u0441\u043e\u043a\u0435\u0442 cqe := &lt;-c.writeChan  if err = cqe.Error(); err != nil { return 0, &amp;net.OpError{Op: \"write\", Net: \"tcp\", Source: c.lAddr, Addr: c.rAddr, Err: err} } if cqe.Res == 0 { err = &amp;net.OpError{Op: \"write\", Net: \"tcp\", Source: c.lAddr, Addr: c.rAddr, Err: io.ErrUnexpectedEOF} }  runtime.KeepAlive(b) return int(cqe.Res), err }  func (c *Conn) Close() error { return syscall.Close(c.Fd) }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>\u041f\u0440\u043e\u0432\u0435\u0440\u0438\u043c \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0435 \u043d\u043e\u0432\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438, \u0434\u0430\u0432\u043d\u043e \u043c\u044b \u043d\u0435 \u043f\u0438\u0441\u0430\u043b\u0438 echo-server! <a href=\"https:\/\/gist.github.com\/godzie44\/190406f64d788ff901f8469aaca61bb6\">\u0412\u043e\u0442 \u0435\u0433\u043e \u043f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434<\/a> (\u0432\u043c\u0435\u0441\u0442\u0435 \u0441 reactor&#8217;\u043e\u043c, net.Listener \u0438 net.Conn).<\/p>\n<p>\u0421\u0440\u0430\u0432\u043d\u0438\u043c \u043d\u043e\u0432\u044b\u0439 \u0441\u0435\u0440\u0432\u0435\u0440 \u0441 io_uring reactor&#8217;\u043e\u043c \u043f\u043e\u0434 \u043a\u0430\u043f\u043e\u0442\u043e\u043c, \u0441 \u0442\u0430\u043a\u0438\u043c \u0436\u0435 \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 net.TCPListener \u0438 net.TCPConn \u0438\u0437 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u043e\u0439 \u0431\u0438\u0431\u0438\u043b\u0438\u043e\u0442\u0435\u043a\u0438 (\u0430 \u0437\u043d\u0430\u0447\u0438\u0442, \u043f\u043e\u0434 \u043a\u0430\u043f\u043e\u0442\u043e\u043c \u0442\u0430\u043c netpoller). \u041a\u0430\u043a \u043e\u0431\u044b\u0447\u043d\u043e \u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043d\u0430 rps.<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<td>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>c: 100    bytes: 128<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>c: 50     bytes: 1024<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>c: 500  bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 500 bytes: 1024<\/p>\n<\/td>\n<td data-colwidth=\"96\" width=\"96\">\n<p>c: 1000 bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 1000 bytes: 1024<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p>net\/http<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>132664<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>139206<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>133039<\/p>\n<\/td>\n<td>\n<p>139171<\/p>\n<\/td>\n<td data-colwidth=\"96\" width=\"96\">\n<p>133480<\/p>\n<\/td>\n<td>\n<p>139617<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p>reactor (io_uring)<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>30892<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>30077<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>39192<\/p>\n<\/td>\n<td>\n<p>38375<\/p>\n<\/td>\n<td data-colwidth=\"96\" width=\"96\">\n<p>46120<\/p>\n<\/td>\n<td>\n<p>51204<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>\u0414\u0430 \u0443\u0436, \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u0435 \u043d\u0435 \u0432 \u043d\u0430\u0448\u0443 \u043f\u043e\u043b\u044c\u0437\u0443. \u0422\u0435\u043a\u0443\u0449\u0430\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u043d\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 \u043d\u0430 \u043f\u043e\u043b\u043d\u0443\u044e \u0440\u0435\u0441\u0443\u0440\u0441\u044b \u0436\u0435\u043b\u0435\u0437\u0430 \u0438 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0438 io_uring\u00a0\u2014\u00a0\u0440\u0430\u0441\u043f\u043b\u0430\u0442\u0430 \u0437\u0430 \u044d\u0442\u043e \u043d\u0438\u0437\u043a\u0430\u044f \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c. \u0422\u0435\u043c \u043d\u0435 \u043c\u0435\u043d\u0435\u0435 \u0432 \u043f\u043b\u0430\u043d\u0435 \u0444\u0443\u043d\u043a\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u0434\u0430\u0436\u0435 \u0442\u0430\u043a\u043e\u0439, \u043d\u0430\u0438\u0432\u043d\u043e\u0439, \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 reactor \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0447\u0442\u043e\u0431\u044b \u0437\u0430\u043c\u0435\u043d\u0438\u0442\u044c \u0441\u043e\u0431\u043e\u0439 netpoller. \u041a\u0440\u043e\u043c\u0435 \u0442\u043e\u0433\u043e, reactor \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0435 socket I\/O,\u00a0\u043d\u043e \u0438 \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u043f\u0440\u043e\u0447\u0438\u0445 I\/O.<\/p>\n<figure class=\"full-width\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w780q1\/getpro\/habr\/upload_files\/e89\/e3d\/1ce\/e89e3d1ce53ba55d9042d153dc7d06e2.jpg\" width=\"1332\" height=\"1116\" data-src=\"https:\/\/habrastorage.org\/getpro\/habr\/upload_files\/e89\/e3d\/1ce\/e89e3d1ce53ba55d9042d153dc7d06e2.jpg\" data-blurred=\"true\"\/><figcaption><\/figcaption><\/figure>\n<h2>\u041e \u0437\u0430\u0432\u0435\u0440\u0448\u0430\u044e\u0449\u0435\u0439 \u0447\u0430\u0441\u0442\u0438<\/h2>\n<p>\u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u0442\u0430\u043a\u0430\u044f \u043d\u0438\u0437\u043a\u0430\u044f \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043d\u0435 \u043c\u043e\u0436\u0435\u0442 \u043d\u0430\u0441 \u0443\u0441\u0442\u0440\u043e\u0438\u0442\u044c. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0432 \u0442\u0440\u0435\u0442\u044c\u0435\u0439 \u0438 \u0437\u0430\u043a\u043b\u044e\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0439 \u0447\u0430\u0441\u0442\u0438\u00a0\u0440\u0430\u0437\u0431\u0435\u0440\u0435\u043c\u0441\u044f, \u043f\u043e\u0447\u0435\u043c\u0443 \u0440\u0435\u0448\u0435\u043d\u0438\u0435 \u0441 &#171;\u043d\u0430\u0438\u0432\u043d\u044b\u043c&#187; reactor \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0442\u0430\u043a \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u043e, \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0441\u043f\u043e\u0441\u043e\u0431\u044b \u0443\u0441\u043a\u043e\u0440\u0435\u043d\u0438\u044f (\u043a\u0430\u043a \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 io_uring, \u0442\u0430\u043a \u0438 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0430\u0446\u0438\u0439 \u043a\u043e\u0434\u0430 reactor), \u0430 \u0442\u0430\u043a\u0436\u0435 \u043f\u043e\u0441\u0442\u0430\u0432\u0438\u043c \u0442\u043e\u0447\u043a\u0443 (\u0445\u043e\u0442\u044f \u0441\u043a\u043e\u0440\u0435\u0435\u00a0\u043c\u043d\u043e\u0433\u043e\u0442\u043e\u0447\u0438\u0435) \u0432 \u0431\u0438\u0442\u0432\u0435 \u0441 netpoller. \u0421\u043f\u0430\u0441\u0438\u0431\u043e \u0437\u0430 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435, stay tuned.<\/p>\n<hr\/>\n<p>\u0414\u0430\u0442\u0430-\u0446\u0435\u043d\u0442\u0440 ITSOFT \u2014 \u0440\u0430\u0437\u043c\u0435\u0449\u0435\u043d\u0438\u0435 \u0438 \u0430\u0440\u0435\u043d\u0434\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u0432 \u0438 \u0441\u0442\u043e\u0435\u043a \u0432 \u0434\u0432\u0443\u0445 \u0434\u0430\u0442\u0430-\u0446\u0435\u043d\u0442\u0440\u0430\u0445 \u0432 \u041c\u043e\u0441\u043a\u0432\u0435. \u0417\u0430 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0438\u0435 \u0433\u043e\u0434\u044b UPTIME 100%. \u0420\u0430\u0437\u043c\u0435\u0449\u0435\u043d\u0438\u0435 GPU-\u0444\u0435\u0440\u043c \u0438 ASIC-\u043c\u0430\u0439\u043d\u0435\u0440\u043e\u0432, \u0430\u0440\u0435\u043d\u0434\u0430 GPU-\u0441\u0435\u0440\u0432\u0435\u0440\u043e\u0432, \u043b\u0438\u0446\u0435\u043d\u0437\u0438\u0438 \u0441\u0432\u044f\u0437\u0438, SSL-\u0441\u0435\u0440\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u044b, \u0430\u0434\u043c\u0438\u043d\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u0432 \u0438 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0430 \u0441\u0430\u0439\u0442\u043e\u0432.<\/p>\n<\/div>\n<\/div>\n<p> <!----> <!----><br \/> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/company\/itsoft\/blog\/597745\/\"> https:\/\/habr.com\/ru\/company\/itsoft\/blog\/597745\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<div><\/div>\n<div id=\"post-content-body\" class=\"article-formatted-body article-formatted-body_version-2\">\n<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<figure class=\"full-width\"><figcaption><\/figcaption><\/figure>\n<p>\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442! \u041f\u0440\u043e\u0434\u043e\u043b\u0436\u0430\u0435\u043c \u0440\u0430\u0437\u0431\u0438\u0440\u0430\u0442\u044c\u0441\u044f \u0441 io_uring. \u0421\u0435\u0433\u043e\u0434\u043d\u044f \u043f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c io_uring \u0434\u043b\u044f \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u043f\u0440\u0438\u043a\u043b\u0430\u0434\u043d\u044b\u0445 \u0437\u0430\u0434\u0430\u0447. \u0421\u043d\u0430\u0447\u0430\u043b\u0430 \u043c\u0438\u0433\u0440\u0438\u0440\u0443\u0435\u043c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0438\u0437 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0433\u043e \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u0430 \u0441 C \u043d\u0430 GO, \u0437\u0430\u0442\u0435\u043c \u043f\u043e\u0434\u0433\u043e\u0442\u043e\u0432\u0438\u043c \u043f\u043e\u0447\u0432\u0443 \u0434\u043b\u044f \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044f \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u044b\u0445 TCP \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u0432. \u041d\u0443 \u0438 \u0431\u0435\u0437 \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044f \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u043d\u0435 \u043e\u0431\u043e\u0439\u0434\u0435\u0442\u0441\u044f. \u041e\u0431\u043e\u0439\u0434\u0435\u043c\u0441\u044f \u0431\u0435\u0437 \u0434\u043b\u0438\u043d\u043d\u043e\u0433\u043e \u0432\u0441\u0442\u0443\u043f\u043b\u0435\u043d\u0438\u044f, \u0432\u043f\u0435\u0440\u0435\u0434 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c!<\/p>\n<hr\/>\n<h2>\u0414\u0438\u0441\u043a\u043b\u0435\u0439\u043c\u0435\u0440<\/h2>\n<p>\u042d\u0442\u043e \u0432\u0442\u043e\u0440\u0430\u044f \u0441\u0442\u0430\u0442\u044c\u044f \u0438\u0437 \u0441\u0435\u0440\u0438\u0438, \u043f\u043e\u0441\u0432\u044f\u0449\u0435\u043d\u043d\u043e\u0439 io_uring. \u0427\u0442\u043e\u0431\u044b \u043f\u043e\u043d\u0438\u043c\u0430\u0442\u044c, \u043e \u0447\u0435\u043c \u0440\u0435\u0447\u044c \u2014 \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u044c\u0442\u0435\u0441\u044c \u0441 <a href=\"https:\/\/habr.com\/ru\/company\/itsoft\/blog\/589389\/\">\u043f\u0435\u0440\u0432\u044b\u043c \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u043e\u043c<\/a>.\u00a0\u00a0<\/p>\n<p>\u0421\u0435\u0433\u043e\u0434\u043d\u044f \u043e\u0441\u0442\u0430\u0432\u0438\u043c \u0432 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u0442\u0435\u043e\u0440\u0438\u044e io_uring, \u043d\u043e c\u0444\u043e\u043a\u0443\u0441\u0438\u0440\u0443\u0435\u043c\u0441\u044f \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u0430\u0441\u043f\u0435\u043a\u0442\u0430\u0445 \u043f\u0440\u0438\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u044d\u0442\u043e\u0439 \u0442\u0435\u0445\u043d\u043e\u043b\u043e\u0433\u0438\u0438, \u0442\u0430\u043a \u0447\u0442\u043e \u043a\u043e\u0434\u0430 \u0431\u0443\u0434\u0435\u0442 \u043c\u043d\u043e\u0433\u043e. \u0414\u043b\u044f \u043f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u043e\u0432 \u0431\u044b\u043b\u0430 \u0432\u044b\u0431\u0440\u0430\u043d\u0430 \u0440\u0430\u0431\u043e\u0442\u0430 \u0441 \u0441\u043e\u043a\u0435\u0442\u0430\u043c\u0438, \u0430 \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u044d\u0442\u0430\u043b\u043e\u043d\u0430 \u2014 runtime GO. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u0432 \u044d\u0442\u043e\u043c \u043c\u0430\u0442\u0435\u0440\u0438\u0430\u043b\u0435, \u043a\u043e\u0434 \u0431\u0443\u0434\u0435\u0442 \u043d\u0430 \u044f\u0437\u044b\u043a\u0435 GO, \u0434\u0430 \u0438 \u043f\u0440\u0438\u043c\u0435\u043d\u0435\u043d\u0438\u0435 io_uring \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0432 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0435 GO.<\/p>\n<p>\u0415\u0441\u043b\u0438 \u0434\u0430\u043d\u043d\u0430\u044f \u0442\u0435\u043c\u0430 \u0431\u0443\u0434\u0435\u0442 \u043d\u0435\u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u0430, \u0442\u043e \u043f\u043e\u0434\u0445\u043e\u0434\u0438\u0442\u0435 \u043a \u0441\u0442\u0430\u0442\u044c\u0435 \u043d\u043e\u043c\u0435\u0440 3. \u0422\u0430\u043c \u0441\u043d\u043e\u0432\u0430 \u0431\u0443\u0434\u0435\u0442 \u043e\u0431\u0441\u0443\u0436\u0434\u0435\u043d\u0438\u0435 \u0444\u0438\u0447 io_uring, \u043d\u0430\u0441\u0442\u0440\u043e\u0435\u043a \u0438 \u0440\u0435\u0436\u0438\u043c\u043e\u0432 \u0440\u0430\u0431\u043e\u0442\u044b, \u0442\u044e\u043d\u0438\u043d\u0433\u0430 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438.<\/p>\n<h2>Echo-\u0441\u0435\u0440\u0432\u0435\u0440, \u0442\u0443\u0448\u0451\u043d\u044b\u0439 \u0441 \u043f\u0440\u0438\u043f\u0440\u0430\u0432\u0430\u043c\u0438  <\/h2>\n<figure class=\"full-width\"><figcaption><\/figcaption><\/figure>\n<p>\u041f\u0440\u0435\u0436\u0434\u0435 \u0447\u0435\u043c \u0441\u043e\u043f\u0435\u0440\u043d\u0438\u0447\u0430\u0442\u044c \u0441 runtime&#8217;\u043e\u043c GO, \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u043f\u043e\u0433\u043e\u0432\u043e\u0440\u0438\u043c \u043e\u0431 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0435, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0443\u0434\u0435\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c. \u0414\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 io_uring \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0432\u043e\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u0441\u0432\u044f\u0437\u043a\u043e\u0439 CGO + liburing, \u043d\u043e, \u0442\u0430\u043a \u043a\u0430\u043a \u043e\u0441\u043e\u0431\u044b\u0445 \u043f\u043e\u043c\u0435\u0445 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u043c\u0438 \u0432\u044b\u0437\u043e\u0432\u0430\u043c\u0438 \u0441\u0435\u043c\u0435\u0439\u0441\u0442\u0432\u0430 io_uring \u0432 GO \u043d\u0435\u0442 (\u043d\u0443 \u043b\u0430\u0434\u043d\u043e, \u043e\u043d\u0438 \u0435\u0441\u0442\u044c, \u043d\u043e \u0433\u043e\u0432\u043e\u0440\u0438\u0442\u044c \u0441\u0435\u0433\u043e\u0434\u043d\u044f \u043e \u043d\u0438\u0445 \u043d\u0435 \u0431\u0443\u0434\u0435\u043c), \u043f\u043e\u0447\u0435\u043c\u0443 \u0431\u044b \u043d\u0435 \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u043f\u043e\u043b\u043d\u043e\u0441\u0442\u044c\u044e \u043d\u0430\u0442\u0438\u0432\u043d\u0443\u044e \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0443? \u0414\u0430\u0432\u0430\u0439\u0442\u0435 \u043f\u0435\u0440\u0435\u043f\u0438\u0448\u0435\u043c echo-\u0441\u0435\u0440\u0432\u0435\u0440 \u0438\u0437 \u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0438 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 <a href=\"https:\/\/github.com\/godzie44\/go-uring\">go-uring<\/a>:<\/p>\n<details class=\"spoiler\">\n<summary>GO echo-server<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">package main  import ( \"errors\" \"flag\" \"fmt\" \"github.com\/godzie44\/go-uring\/uring\" \"log\" \"strconv\" \"syscall\" )  const MaxConns = 4096 const Backlog = 512 const MaxMsgLen = 2048  type connType int  const ( _ connType = iota ACCEPT READ WRITE )  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0431\u0443\u0434\u0435\u043c \u0434\u0435\u0440\u0436\u0430\u0442\u044c \u0432 \u043f\u0430\u043c\u044f\u0442\u0438 connInfo \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443. \/\/ fd \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0441\u043e\u043a\u0435\u0442\u0430. \/\/ typ - \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u043e\u043a\u0435\u0442 (\u043e\u0436\u0438\u0434\u0430\u0435\u0442 \u0447\u0442\u0435\u043d\u0438\u044f\/\u0437\u0430\u043f\u0438\u0441\u0438\/accept'\u0430). \/\/ sendOp, recvOp - \u0437\u0430\u043a\u0435\u0448\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0447\u0442\u0435\u043d\u0438\u044f \u0438\u0437 \u0441\u043e\u043a\u0435\u0442\u0430\/\u0437\u0430\u043f\u0438\u0441\u0438 \u0432 \u0441\u043e\u043a\u0435\u0442. type connInfo struct { fd  int typ connType  sendOp *uring.SendOp recvOp *uring.RecvOp }  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043f\u0440\u0435\u0434\u0430\u043b\u043e\u0446\u0438\u0440\u0443\u0435\u043c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0447\u0442\u0435\u043d\u0438\u044f \u0438 \u0437\u0430\u043f\u0438\u0441\u0438. \/\/ \u041f\u0435\u0440\u0435\u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044f \u0447\u0442\u0435\u043d\u0438\u044f \u0438 \u0437\u0430\u043f\u0438\u0441\u0438 \u0441\u043d\u0438\u0437\u0438\u0442 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0443 \u043d\u0430 GC. func makeConns() [MaxConns]connInfo { var conns [MaxConns]connInfo for fd := range conns { conns[fd].recvOp = uring.Recv(uintptr(fd), nil, 0) conns[fd].sendOp = uring.Send(uintptr(fd), nil, 0) } return conns }  \/\/ \u0411\u0443\u0444\u0435\u0440 \u0434\u043b\u044f \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439. var conns = makeConns()  \/\/ \u0414\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \u0431\u0443\u0444\u0435\u0440\u0430 \u0434\u043b\u044f \u0437\u0430\u043f\u0438\u0441\u0438\/\u0447\u0442\u0435\u043d\u0438\u044f. func makeBuffers() [][]byte { buffs := make([][]byte, MaxConns) for i := range buffs { buffs[i] = make([]byte, MaxMsgLen) } return buffs }  var buffs = makeBuffers()  func main() { flag.Parse() port, _ := strconv.Atoi(flag.Arg(0))    \/\/ \u0421\u043e\u0437\u0434\u0430\u0435\u043c \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u044b\u0439 \u0441\u043e\u043a\u0435\u0442 \u0438 \u0441\u043b\u0443\u0448\u0430\u0435\u043c \u043f\u043e\u0440\u0442.  \/\/ \u041e\u0442\u043c\u0435\u0442\u0438\u043c, \u0447\u0442\u043e \u043f\u0440\u0438 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0441\u043e\u043a\u0435\u0442\u0430 \u0444\u043b\u0430\u0433 O_NON_BLOCK \u043d\u0435 \u0443\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442\u0441\u044f, \/\/ \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u0432\u0441\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 read\/write \u0438 \u0442\u0434 \u043f\u0440\u0435\u043e\u0431\u0440\u0430\u0437\u0443\u044e\u0442\u0441\u044f \u0432 \u043d\u0435\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u043d\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b \u0432\u043d\u0443\u0442\u0440\u0438 io_uring serverSockFd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, 0) checkErr(err) defer syscall.Close(serverSockFd)  checkErr(syscall.SetsockoptInt(serverSockFd, syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1))  checkErr(syscall.Bind(serverSockFd, &amp;syscall.SockaddrInet4{ Port: port, })) checkErr(syscall.Listen(serverSockFd, Backlog))  fmt.Printf(\"io_uring echo server listening for connections on port: %d\\n\", port)  \/\/ \u0421\u043e\u0437\u0434\u0430\u0435\u043c \u044d\u043a\u0437\u0435\u043c\u043f\u043b\u044f\u0440 io_uring, \u043d\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c \u043d\u0438\u043a\u0430\u043a\u0438\u0435 \u043a\u0430\u0441\u0442\u043e\u043c\u043d\u044b\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438. \/\/ \u0412\u043c\u0435\u0441\u0442\u0438\u043c\u043e\u0441\u0442\u044c SQ\/SQ \u0431\u0443\u0444\u0435\u0440\u043e\u0432 \u0443\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u043c \u0432 4096 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u0432. ring, err := uring.New(4096) checkErr(err) defer ring.Close()  \/\/ \u041f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0444\u0438\u0447\u0438 IORING_FEAT_FAST_POLL.   \/\/ \u0414\u043b\u044f \u043d\u0430\u0441 \u044d\u0442\u043e \u043d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \"\u043f\u0435\u0440\u0444\u043e\u0440\u043c\u044f\u0449\u0430\u044f\" \u0444\u0438\u0447\u0430 \u0432 \u0434\u0430\u043d\u043d\u043e\u043c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438,   \/\/ \u0444\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u044d\u0442\u043e \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0439 \u0432 io_uring \u0434\u0432\u0438\u0436\u043e\u043a \u0434\u043b\u044f \u043f\u043e\u043b\u043b\u0438\u043d\u0433\u0430 I\/O. if !ring.Params.FastPollFeature() { checkErr(errors.New(\"IORING_FEAT_FAST_POLL not available\")) }  \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u043f\u0435\u0440\u0432\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0432 SQ - \u0441\u043b\u0443\u0448\u0430\u0435\u043c \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u044b\u0439 \u0441\u043e\u043a\u0435\u0442 \u043d\u0430 \u043f\u0440\u0435\u0434\u043c\u0435\u0442 \u043d\u043e\u0432\u044b\u0445 \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0445 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439. acceptOp := uring.Accept(uintptr(serverSockFd), 0) addAccept(ring, acceptOp)  cqes := make([]*uring.CQEvent, Backlog)  var cqe *uring.CQEvent for { \/\/ \u0421\u0430\u0431\u043c\u0438\u0442\u0438\u043c \u0432\u0441\u0435 SQE \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0431\u044b\u043b\u0438 \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u044b \u043d\u0430 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439 \u0438\u0442\u0435\u0440\u0430\u0446\u0438\u0438.. _, err = ring.Submit() checkErr(err)  \/\/ \u0416\u0434\u0435\u043c \u043a\u043e\u0433\u0434\u0430 \u0432 CQ \u0431\u0443\u0444\u0435\u0440\u0435 \u043f\u043e\u044f\u0432\u0438\u0442\u0441\u044f \u0445\u043e\u0442\u044f \u0431\u044b \u043e\u0434\u043d\u043e CQE. _, err = ring.WaitCQEvents(1) if errors.Is(err, syscall.EAGAIN) || errors.Is(err, syscall.EINTR) { continue } checkErr(err)  \/\/ \u041f\u043e\u043c\u0435\u0449\u0430\u0435\u043c \u0432\u0441\u0435 \"\u0433\u043e\u0442\u043e\u0432\u044b\u0435\" CQE \u0432 \u0431\u0443\u0444\u0435\u0440 cqes. n := ring.PeekCQEventBatch(cqes)  for i := 0; i &lt; n; i++ { cqe = cqes[i]        \/\/ \u0412 \u043f\u043e\u043b\u0435 user_data \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0438\u043d\u0434\u0435\u043a\u0441 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0435\u0433\u043e connInfo       \/\/ \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u043b\u0443\u0436\u0435\u0431\u043d\u0430\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f \u043f\u043e \u0441\u043e\u043a\u0435\u0442\u0443. ud := conns[cqe.UserData] typ := ud.typ res := cqe.Res  ring.SeenCQE(cqe)  \/\/ \u041f\u0440\u043e\u0432\u0435\u0440\u044f\u044f \u0442\u0438\u043f \u043c\u044b \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u0446\u0438\u0440\u0443\u0435\u043c \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0432 CQE (accept \/ recv \/ send). switch typ { case ACCEPT: addRead(ring, int(res)) addAccept(ring, acceptOp) case READ: if res &lt;= 0 { _ = syscall.Shutdown(ud.fd, syscall.SHUT_RDWR) } else { addWrite(ring, ud.fd, res) } case WRITE: addRead(ring, ud.fd) } } } }  \/\/ addAccept - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ accept \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u0441\u0435\u0440\u0432\u0435\u0440 \u0441\u043e\u043a\u0435\u0442\u0430. func addAccept(ring *uring.Ring, acceptOp *uring.AcceptOp) { conns[acceptOp.Fd()].fd = acceptOp.Fd() conns[acceptOp.Fd()].typ = ACCEPT  err := ring.QueueSQE(acceptOp, 0, uint64(acceptOp.Fd())) checkErr(err) }  \/\/ addRead - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ read \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430. func addRead(ring *uring.Ring, fd int) { buff := buffs[fd]  ci := &amp;conns[fd] ci.fd = fd ci.typ = READ ci.recvOp.SetBuffer(buff)  err := ring.QueueSQE(ci.recvOp, 0, uint64(fd)) checkErr(err) }  \/\/ addWrite - \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0432 SQ write \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e, fd - \u0444\u0430\u0439\u043b\u043e\u0432\u044b\u0439 \u0434\u0435\u0441\u043a\u0440\u0438\u043f\u0442\u043e\u0440 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430. func addWrite(ring *uring.Ring, fd int, bytesRead int32) { buff := buffs[fd]  ci := &amp;conns[fd] ci.fd = fd ci.typ = WRITE ci.sendOp.SetBuffer(buff[:bytesRead])  err := ring.QueueSQE(ci.sendOp, 0, uint64(fd)) checkErr(err) }  func checkErr(err error) { if err != nil { log.Fatal(err) } }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>\u041a\u043e\u0434 \u043d\u0430 GO \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0441\u044f \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043a\u043e\u043c\u043f\u0430\u043a\u0442\u043d\u0435\u0435 \u0447\u0435\u043c <a href=\"https:\/\/github.com\/frevib\/io_uring-echo-server\/blob\/master\/io_uring_echo_server.c\">\u044d\u0442\u043e\u0442 \u0436\u0435 \u0441\u0435\u0440\u0432\u0435\u0440<\/a> \u043d\u0430 plain C. \u0421 \u0434\u0440\u0443\u0433\u043e\u0439 \u0441\u0442\u043e\u0440\u043e\u043d\u044b, \u043e\u0431\u0430 \u0438\u0441\u0445\u043e\u0434\u043d\u0438\u043a\u0430 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0441\u0445\u043e\u0436\u0438 \u043a\u0430\u043a \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u0447\u0435\u0441\u043a\u0438, \u0442\u0430\u043a \u0438 \u0441\u0438\u043d\u0442\u0430\u043a\u0441\u0438\u0447\u0435\u0441\u043a\u0438. \u0410 \u0447\u0442\u043e \u043f\u043e \u043f\u043e\u0432\u043e\u0434\u0443 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438? \u0421 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u044b\u043c \u043e\u043f\u0438\u0441\u0430\u043d\u0438\u0435\u043c \u043c\u0435\u0442\u043e\u0434\u0438\u043a\u0438 \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044f \u043c\u043e\u0436\u043d\u043e \u043e\u0437\u043d\u0430\u043a\u043e\u043c\u0438\u0442\u044c\u0441\u044f <a href=\"https:\/\/github.com\/godzie44\/go-uring\/blob\/master\/example\/echo-server\/benchmark.md\">\u0437\u0434\u0435\u0441\u044c<\/a>. \u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0438\u0441\u043a\u043b\u044e\u0447\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b:<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>c: 100    bytes: 128<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>c: 50     bytes: 1024<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>c: 500  bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 500 bytes: 1024<\/p>\n<\/td>\n<td>\n<p>c: 1000 bytes: 128<\/p>\n<\/td>\n<td>\n<p>c: 1000 bytes: 1024<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<p>io_uring-echo-server (C lang)<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>235356<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>224783<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>173670<\/p>\n<\/td>\n<td>\n<p>155477<\/p>\n<\/td>\n<td>\n<p>149407<\/p>\n<\/td>\n<td>\n<p>139987<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td data-colwidth=\"96\" width=\"96\">\n<p>echo-server<\/p>\n<\/td>\n<td data-colwidth=\"94\" width=\"94\">\n<p>227884<\/p>\n<\/td>\n<td data-colwidth=\"97\" width=\"97\">\n<p>222709<\/p>\n<\/td>\n<td data-colwidth=\"93\" width=\"93\">\n<p>169001<\/p>\n<\/td>\n<td>\n<p>150275<\/p>\n<\/td>\n<td>\n<p>143664<\/p>\n<\/td>\n<td>\n<p>128783<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>\u041e\u0442\u043b\u0438\u0447\u043d\u043e! GO-\u043a\u043e\u0434 \u043d\u0435 \u0441\u0438\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0438\u0433\u0440\u044b\u0432\u0430\u0435\u0442 \u043a\u043e\u0434\u0443 \u043d\u0430 C \u0432 \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0435 I\/O \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438. \u041d\u043e, \u0435\u0441\u0442\u044c \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430, \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0442\u0440\u0430\u043d\u0441\u043f\u043e\u0440\u0442\u043d\u043e\u0433\u043e \u0441\u043b\u043e\u044f \u043f\u0440\u0438\u0431\u0438\u0442\u0430 \u0433\u0432\u043e\u0437\u0434\u044f\u043c\u0438 \u043a \u043b\u043e\u0433\u0438\u043a\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f, \u0447\u0442\u043e \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0435\u0435 \u0433\u0434\u0435-\u043b\u0438\u0431\u043e \u043a\u0440\u043e\u043c\u0435 \u043a\u0430\u043a \u0432 echo-\u0441\u0435\u0440\u0432\u0435\u0440\u0435. \u0414\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u043f\u0438\u0441\u0430\u0442\u044c \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u044b\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0441 io_uring \u0432 GO, \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u044b \u0438\u0437 \u043f\u0430\u043a\u0435\u0442\u0430 net: net.Conn \u0438 net.Listener. \u0410 \u0434\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u043d\u0443\u0436\u043d\u043e \u0440\u0430\u0437\u043e\u0431\u0440\u0430\u0442\u044c\u0441\u044f \u0432 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u0445 net.Conn \u0438 net.Listener \u0434\u043b\u044f \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 TCP \u0438 \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438. \u041d\u043e \u043e\u0431\u043e \u0432\u0441\u0435\u043c \u043f\u043e \u043f\u043e\u0440\u044f\u0434\u043a\u0443.  <\/p>\n<h3>\u0412 \u043b\u043e\u0433\u043e\u0432\u0435 net package<\/h3>\n<p>\u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u044b\u0435 \u043d\u0430\u043c \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u044b \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435.<\/p>\n<h4>net.Listener<\/h4>\n<p>\u0417\u0430\u0434\u0430\u0447\u0430 listener&#8217;\u0430 \u2014 \u0441\u043b\u0443\u0448\u0430\u0442\u044c \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u043f\u043e\u0440\u0442 \u0438 \u043f\u0440\u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043a \u0441\u0435\u0440\u0432\u0435\u0440\u0443 \u043e\u0447\u0435\u0440\u0435\u0434\u043d\u043e\u0433\u043e \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0443\u044e net.Conn, \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u044d\u0442\u0438\u043c \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u043c. \u0421\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441:<\/p>\n<pre><code class=\"go\">\/\/ A Listener is a generic network listener for stream-oriented protocols. \/\/ \/\/ Multiple goroutines may invoke methods on a Listener simultaneously. type Listener interface { \/\/ Accept waits for and returns the next connection to the listener. Accept() (Conn, error)  \/\/ Close closes the listener. \/\/ Any blocked Accept operations will be unblocked and return errors. Close() error  \/\/ Addr returns the listener's network address. Addr() Addr }<\/code><\/pre>\n<h4>net.Conn<\/h4>\n<p>net.Conn &#8212; \u0430\u0431\u0441\u0442\u0440\u0430\u043a\u0446\u0438\u044f \u043d\u0430\u0434 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435\u043c, \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u0442\u044c \u0447\u0442\u0435\u043d\u0438\u0435 \u0438 \u0437\u0430\u043f\u0438\u0441\u044c \u0432 \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0439 \u0441\u043e\u043a\u0435\u0442. \u0418\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 (\u0434\u043b\u044f \u0443\u0434\u043e\u0431\u0441\u0442\u0432\u0430 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0443\u043f\u0440\u043e\u0449\u0435\u043d):<\/p>\n<pre><code class=\"go\">type Conn interface{ \/\/ Read reads data from the connection. Read(b []byte) (n int, err error)  \/\/ Write writes data to the connection. Write(b []byte) (n int, err error)  \/\/ Close closes the connection. Close() error }<\/code><\/pre>\n<p>\u0421\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 \u044d\u0442\u0438\u0445 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u043e\u0432 \u043b\u0435\u0436\u0430\u0442 \u0432 \u043e\u0441\u043d\u043e\u0432\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0442\u0440\u0430\u043d\u0441\u043f\u043e\u0440\u0442\u043d\u043e\u0433\u043e \u0443\u0440\u043e\u0432\u043d\u044f \u0432 GO. \u0418\u043c\u0435\u044f \u043d\u0430 \u0440\u0443\u043a\u0430\u0445 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438 net.Listner \u0438 net.Conn \u0434\u043b\u044f, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, TCP \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 \u043c\u043e\u0436\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u0442\u044c \u043b\u044e\u0431\u043e\u0439 \u0432\u044b\u0448\u0435\u0441\u0442\u043e\u044f\u0449\u0438\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b, \u0431\u0443\u0434\u044c \u0442\u043e HTTP \u0438\u043b\u0438 \u043b\u044e\u0431\u043e\u0439 \u0434\u0440\u0443\u0433\u043e\u0439. \u041a \u043f\u0440\u0438\u043c\u0435\u0440\u0443, \u0432\u043e\u0442 \u0442\u0430\u043a\u00a0\u0431\u0443\u0434\u0435\u0442 \u0432\u044b\u0433\u043b\u044f\u0434\u0435\u0442\u044c echo-server \u0441 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435\u043c \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u0445 net.TCPListener \u0438 net.TCPConn:<\/p>\n<details class=\"spoiler\">\n<summary>\u043e\u0431\u044b\u0447\u043d\u044b\u0439 echo-server<\/summary>\n<div class=\"spoiler__content\">\n<pre><code class=\"go\">package main  import ( \"io\" \"log\" \"net\" )  const MaxConns = 4096 const MaxMsgLen = 2048  func initBuffs() [][]byte { buffs := make([][]byte, MaxConns) for i := range buffs { buffs[i] = make([]byte, MaxMsgLen) } return buffs }  var buffs = initBuffs()  func main() { listener, err := net.ListenTCP(\"tcp\", &amp;net.TCPAddr{ Port: 8080, }) checkErr(err)  for { conn, err := listener.Accept() checkErr(err)  go handleConn(conn) } }  func handleConn(conn net.Conn) { f, _ := conn.(*net.TCPConn).File() buff := buffs[int(f.Fd())] for { n, err := conn.Read(buff) if err == io.EOF || n == 0 { checkErr(conn.Close()) return } checkErr(err)  _, err = conn.Write(buff[:n]) checkErr(err) } }  func checkErr(err error) { if err != nil { log.Fatal(err) } }<\/code><\/pre>\n<\/div>\n<\/details>\n<p>\u0412\u0441\u0435 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e, \u0432 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e\u043c \u0446\u0438\u043a\u043b\u0435 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0435\u043c \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0435 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0430 \u0437\u0430\u0442\u0435\u043c, \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0443 \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u043c \u0447\u0438\u0442\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0438\u0437 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0441\u043e\u043a\u0435\u0442\u0430 \u0438 \u043f\u0438\u0441\u0430\u0442\u044c \u0442\u0443\u0434\u0430 \u0436\u0435. \u041d\u043e \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u044c\u0442\u0435, \u0447\u0442\u043e \u043a\u0430\u043a\u043e\u0439-\u0442\u043e \u0438\u0437 \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u0432 \u0440\u0435\u0448\u0438\u043b \u043d\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u043d\u0430\u043c \u0434\u0430\u043d\u043d\u044b\u0435, \u043a \u043f\u0440\u0438\u043c\u0435\u0440\u0443, \u0432 \u0442\u0435\u0447\u0435\u043d\u0438\u0435 \u043c\u0438\u043d\u0443\u0442\u044b. \u0412 \u0442\u0430\u043a\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043f\u043e\u0442\u043e\u043a, \u043d\u0430 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e\u0449\u0430\u044f \u0447\u0442\u0435\u043d\u0438\u0435, \u0437\u0430\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u0435\u0442\u0441\u044f? \u0415\u0441\u0442\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u043d\u0435\u0442! \u041b\u044e\u0431\u043e\u0439 GO \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a \u0437\u043d\u0430\u0435\u0442 \u2014 \u044d\u0442\u043e \u043d\u0435 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430. \u041d\u043e \u043a\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c, \u043a\u0430\u0437\u0430\u043b\u043e\u0441\u044c \u0431\u044b, \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0435 \u0432\u044b\u0437\u043e\u0432\u044b <em>conn.Read<\/em> \u043d\u0435 \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0442 \u043f\u043e\u0442\u043e\u043a \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f? \u0418 \u0442\u0443\u0442 \u0432 \u0434\u0435\u043b\u043e \u0432\u0441\u0442\u0443\u043f\u0430\u0435\u0442 runtime, \u0432\u0435\u0440\u043d\u0435\u0435 \u0435\u0433\u043e \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442 \u2014 netpoller.<\/p>\n<h2>netpoller &#8212; \u0442\u0440\u043e\u043f\u0430 \u0447\u0435\u0440\u0435\u0437 block I\/O<\/h2>\n<p>\u0420\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043a\u0430\u043a \u0433\u043e\u0440\u0443\u0442\u0438\u043d\u044b<\/p>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-327151","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/327151","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=327151"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/327151\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=327151"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=327151"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=327151"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}