chore: 升级task版本

Author: guonaihong

conn.go

@@ -44,11 +44,11 @@ func newConn(fd int, safeConns *core.SafeConns[Conn],
 	var taskExecutor driver.TaskExecutor
 	switch taskType {
 	case TaskTypeInConnectionGoroutine:
-		taskExecutor = task.newTask("stream")
+		taskExecutor = task.newTask("onebyone")
 	case TaskTypeInEventLoop:
 		// 不做任何事情
 	case TaskTypeInBusinessGoroutine:
-		taskExecutor = task.newTask("stream2")
+		taskExecutor = task.newTask("stream")
 	default:
 		panic("invalid task type")
 	}

go.mod

@@ -3,7 +3,7 @@ module github.com/antlabs/pulse
 go 1.24.1
 
 require (
-	github.com/antlabs/task v0.0.0-20250615065052-8249dcd16d96
+	github.com/antlabs/task v0.0.0-20250629140636-3fd744b4c2c7
 	golang.org/x/sys v0.31.0
 )
 

go.sum

@@ -1,5 +1,5 @@
-github.com/antlabs/task v0.0.0-20250615065052-8249dcd16d96 h1:C1nFdgUt1n2F/zwpIu+sit6BIVvpUScFQC4KePsvLzU=
-github.com/antlabs/task v0.0.0-20250615065052-8249dcd16d96/go.mod h1:6YSWbWdHmW/4s9L0RkmiSCqAf0qmhmb119yzaSbJXww=
+github.com/antlabs/task v0.0.0-20250629140636-3fd744b4c2c7 h1:Q+whQMX7LjTNx2zp56ZBlz5NnzeBMy8U2i/RaLSmlJM=
+github.com/antlabs/task v0.0.0-20250629140636-3fd744b4c2c7/go.mod h1:6YSWbWdHmW/4s9L0RkmiSCqAf0qmhmb119yzaSbJXww=
 github.com/ebitengine/purego v0.8.4 h1:CF7LEKg5FFOsASUj0+QwaXf8Ht6TlFxg09+S9wz0omw=
 github.com/ebitengine/purego v0.8.4/go.mod h1:iIjxzd6CiRiOG0UyXP+V1+jWqUXVjPKLAI0mRfJZTmQ=
 golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik=

multi_event_loops.go

@@ -15,8 +15,8 @@ import (
 
 	"github.com/antlabs/pulse/core"
 	"github.com/antlabs/task/task/driver"
+	_ "github.com/antlabs/task/task/onebyone"
 	_ "github.com/antlabs/task/task/stream"
-	_ "github.com/antlabs/task/task/stream2"
 )
 
 type MultiEventLoop struct {
@@ -180,6 +180,8 @@ func (e *MultiEventLoop) ListenAndServe(addr string) error {
 						c.flush()
 					}
 
+					// flowBackPressure 主要是为了和删除读事件的背压模式做对比用的
+					// 目前来看，删除读事件的背压模式更高效
 					if e.options.flowBackPressure && c.needFlush() {
 						if e.options.triggerType == core.TriggerTypeLevel {
 							return