Merge pull request #704 from panjf2000/dev

minor: v2.8.0

Author: panjf2000

.github/workflows/cross-compile-bsd.yml

@@ -31,7 +31,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        go: ['1.20', '1.23']
+        go: ['1.20', '1.24']
         os:
           - ubuntu-latest
     name: Go ${{ matrix.go }} @ ${{ matrix.os }}

.github/workflows/test.yml

@@ -47,16 +47,16 @@ jobs:
           cache: false
 
       - name: Setup and run golangci-lint
-        uses: golangci/golangci-lint-action@v6
+        uses: golangci/golangci-lint-action@v7
         with:
-          version: v1.61.0
-          args: -v -E gofumpt -E gocritic -E misspell -E revive -E godot --timeout 5m
+          version: v2.1.5
+          args: -v -E gocritic -E misspell -E revive -E godot --timeout 5m
   test:
     needs: lint
     strategy:
       fail-fast: false
       matrix:
-        go: ['1.20', '1.23']
+        go: ['1.20', '1.24']
         os:
           - ubuntu-latest
           - macos-latest

.github/workflows/test_gc_opt.yml

@@ -47,16 +47,16 @@ jobs:
           cache: false
 
       - name: Setup and run golangci-lint
-        uses: golangci/golangci-lint-action@v6
+        uses: golangci/golangci-lint-action@v7
         with:
-          version: v1.61.0
-          args: -v -E gofumpt -E gocritic -E misspell -E revive -E godot --timeout 5m
+          version: v2.1.5
+          args: -v -E gocritic -E misspell -E revive -E godot --timeout 5m
   test:
     needs: lint
     strategy:
       fail-fast: false
       matrix:
-        go: ['1.20', '1.23']
+        go: ['1.20', '1.24']
         os:
           - ubuntu-latest
           - macos-latest

.github/workflows/test_poll_opt.yml

@@ -46,16 +46,16 @@ jobs:
           cache: false
 
       - name: Setup and run golangci-lint
-        uses: golangci/golangci-lint-action@v6
+        uses: golangci/golangci-lint-action@v7
         with:
-          version: v1.61.0
-          args: -v -E gofumpt -E gocritic -E misspell -E revive -E godot
+          version: v2.1.5
+          args: -v -E gocritic -E misspell -E revive -E godot
   test:
     needs: lint
     strategy:
       fail-fast: false
       matrix:
-        go: ['1.20', '1.23']
+        go: ['1.20', '1.24']
         os: [ubuntu-latest, macos-latest]
     name: Go ${{ matrix.go }} @ ${{ matrix.os }}
     runs-on: ${{ matrix.os }}

.github/workflows/test_poll_opt_gc_opt.yml

@@ -46,16 +46,16 @@ jobs:
           cache: false
 
       - name: Setup and run golangci-lint
-        uses: golangci/golangci-lint-action@v6
+        uses: golangci/golangci-lint-action@v7
         with:
-          version: v1.61.0
-          args: -v -E gofumpt -E gocritic -E misspell -E revive -E godot
+          version: v2.1.5
+          args: -v -E gocritic -E misspell -E revive -E godot
   test:
     needs: lint
     strategy:
       fail-fast: false
       matrix:
-        go: ['1.20', '1.23']
+        go: ['1.20', '1.24']
         os: [ubuntu-latest, macos-latest]
     name: Go ${{ matrix.go }} @ ${{ matrix.os }}
     runs-on: ${{ matrix.os }}

README.md

@@ -49,6 +49,7 @@ English | [中文](README_ZH.md)
 - [x] Running on `Linux`, `macOS`, `Windows`, and *BSD: `Darwin`/`DragonFlyBSD`/`FreeBSD`/`NetBSD`/`OpenBSD`
 - [x] **Edge-triggered** I/O support
 - [x] Multiple network addresses binding
+- [x] Support registering new connections to event-loops
 
 ## 🕊 Roadmap
 

README_ZH.md

@@ -49,6 +49,7 @@
 - [x] 支持 `Linux`, `macOS`, `Windows` 和 *BSD 操作系统: `Darwin`/`DragonFlyBSD`/`FreeBSD`/`NetBSD`/`OpenBSD`
 - [x] **Edge-triggered** I/O 支持
 - [x] 多网络地址绑定
+- [x] 支持注册新的连接到事件循环
 
 ## 🕊 未来计划
 

acceptor_windows.go

@@ -20,6 +20,7 @@ import (
 	"runtime"
 
 	errorx "github.com/panjf2000/gnet/v2/pkg/errors"
+	"github.com/panjf2000/gnet/v2/pkg/pool/goroutine"
 )
 
 func (eng *engine) listenStream(ln net.Listener) (err error) {
@@ -43,9 +44,9 @@ func (eng *engine) listenStream(ln net.Listener) (err error) {
 			return
 		}
 		el := eng.eventLoops.next(tc.RemoteAddr())
-		c := newTCPConn(tc, el)
+		c := newTCPConn(el, tc, nil)
 		el.ch <- &openConn{c: c}
-		go func(c *conn, tc net.Conn, el *eventloop) {
+		goroutine.DefaultWorkerPool.Submit(func() {
 			var buffer [0x10000]byte
 			for {
 				n, err := tc.Read(buffer[:])
@@ -55,7 +56,7 @@ func (eng *engine) listenStream(ln net.Listener) (err error) {
 				}
 				el.ch <- packTCPConn(c, buffer[:n])
 			}
-		}(c, tc, el)
+		})
 	}
 }
 
@@ -81,7 +82,7 @@ func (eng *engine) ListenUDP(pc net.PacketConn) (err error) {
 			return
 		}
 		el := eng.eventLoops.next(addr)
-		c := newUDPConn(el, pc, pc.LocalAddr(), addr)
+		c := newUDPConn(el, pc, nil, pc.LocalAddr(), addr, nil)
 		el.ch <- packUDPConn(c, buffer[:n])
 	}
 }