add doPool

Author: petar

Makefile

@@ -31,6 +31,8 @@ go.mod: $(MAKEFILE_LIST)
 	echo 'module github.com/xdrpp/goxdr' > go.mod
 	echo 'go 1.24.0' >> go.mod
 	echo 'require golang.org/x/tools v0.31.0' >> go.mod
+	echo 'require github.com/panjf2000/ants/v2 v2.11.3' >> go.mod
+	echo 'require golang.org/x/sync v0.12.0' >> go.mod
 
 depend: always
 	cd / && go install golang.org/x/tools/cmd/goyacc@latest

rpc/driver.go

@@ -9,6 +9,7 @@ import (
 	"sync"
 	"sync/atomic"
 
+	"github.com/panjf2000/ants/v2"
 	"github.com/xdrpp/goxdr/xdr"
 )
 
@@ -201,6 +202,7 @@ type Driver struct {
 	cs       CallSet
 	started  int32
 
+	doPool  *ants.Pool
 	msgPool *MsgPool
 }
 
@@ -239,12 +241,17 @@ func NewDriver(ctx context.Context, mp *MsgPool, t Transport) *Driver {
 		ctx = context.Background()
 	}
 	ctx, cancel := context.WithCancel(ctx)
+	doPool, err := ants.NewPool(200)
+	if err != nil {
+		panic(err)
+	}
 	ret := Driver{
 		Log:     DefaultLog,
 		Lock:    &sync.Mutex{},
 		ctx:     ctx,
 		cancel:  cancel,
 		in:      ReceiveChan(ctx, t),
+		doPool:  doPool,
 		msgPool: mp,
 	}
 	ret.out, ret.outClose = SendChan(t, func(xid uint32, _ error) {