Skip to content

C
ChainGrpcPro
Commit 431b68b4 authored by duanjinfei's avatar duanjinfei
Browse files
Options

increse BroadcastTxArr goroutine

parent 1b7f4888
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
startTest.go
View file @ 431b68b4
...@@ -21,7 +21,7 @@ func init() { ...@@ -21,7 +21,7 @@ func init() {
return return
} }
cfg.StorageAccFileName += ".xlsx" cfg.StorageAccFileName += ".xlsx"
tranArrChan = make(chan []*transaction.TxFromTran, 10000) tranArrChan = make(chan []*transaction.TxFromTran, 1000000)
} }
func startTest() { func startTest() {
...@@ -39,7 +39,7 @@ func startTest() { ...@@ -39,7 +39,7 @@ func startTest() {
if err := transaction.InitBroadcastTxGoroutine(cfg); err != nil { if err := transaction.InitBroadcastTxGoroutine(cfg); err != nil {
log.Errorf("Init broadcast tx goroutine error: %s", err) log.Errorf("Init broadcast tx goroutine error: %s", err)
} }
for i := 0; i < 2; i++ { for i := 0; i < cfg.GoRoutineCount; i++ {
go func() { go func() {
for { for {
select { select {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment