fix: use ParallelTxNum config and uber automaxprocs

cmd/utils/flags.go

@@ -2030,6 +2030,10 @@ func SetEthConfig(ctx *cli.Context, stack *node.Node, cfg *ethconfig.Config) {
 		cfg.ParallelTxUnorderedMerge = ctx.Bool(ParallelTxUnorderedMergeFlag.Name)
 	}
 
+	if ctx.IsSet(ParallelTxNumFlag.Name) {
+		cfg.ParallelTxNum = ctx.Int(ParallelTxNumFlag.Name)
+	}
+
 	if ctx.IsSet(ParallelTxDAGFlag.Name) {
 		cfg.EnableParallelTxDAG = ctx.Bool(ParallelTxDAGFlag.Name)
 	}

core/parallel_state_scheduler.go

@@ -9,14 +9,17 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/log"
+	_ "go.uber.org/automaxprocs"
 )
 
 var runner chan func()
 
-func init() {
-	cpuNum := runtime.NumCPU()
-	runner = make(chan func(), cpuNum)
-	for i := 0; i < cpuNum; i++ {
+func initParallelRunner(targetNum int) {
+	if targetNum == 0 {
+		targetNum = runtime.NumCPU()
+	}
+	runner = make(chan func(), targetNum)
+	for i := 0; i < targetNum; i++ {
 		go func() {
 			for f := range runner {
 				f()

core/pevm_processor.go

@@ -34,6 +34,7 @@ func newPEVMProcessor(config *params.ChainConfig, bc *BlockChain, engine consens
 		StateProcessor: *NewStateProcessor(config, bc, engine),
 		unorderedMerge: bc.vmConfig.EnableParallelUnorderedMerge,
 	}
+	initParallelRunner(bc.vmConfig.ParallelTxNum)
 	log.Info("Parallel execution mode is enabled", "Parallel Num", ParallelNum(),
 		"CPUNum", runtime.NumCPU(), "unorderedMerge", processor.unorderedMerge)
 	return processor