add sign tx arr mux

transaction/signedTx.go

@@ -15,6 +15,7 @@ import (
 	"math/big"
 	"net"
 	"strings"
+	"sync"
 	"sync/atomic"
 	"time"
 )
@@ -34,9 +35,16 @@ type Transactor struct {
 	receivedAddr common.Address
 }
 
+type SignTranArr struct {
+	TranArr []*types.Transaction
+	mux     sync.RWMutex
+}
+
 var (
-	tran           = make(chan *Transactor, 0)
-	tranArr        = make([]*types.Transaction, 0)
+	tran        = make(chan *Transactor, 0)
+	signTranArr = &SignTranArr{
+		TranArr: make([]*types.Transaction, 0),
+	}
 	batchSignCount int32
 )
 
@@ -125,8 +133,8 @@ func SignedTxArr(sendTxAccountArr [][]string, cfg *tool.Config) []*types.Transac
 		}
 	}
 	for {
-		if len(sendTxAccountArr)*cfg.SignCount == int(batchSignCount) {
-			return tranArr
+		if len(sendTxAccountArr)*cfg.SignCount == int(batchSignCount) && len(signTranArr.TranArr) == len(sendTxAccountArr)*cfg.SignCount {
+			return signTranArr.TranArr
 		}
 	}
 }
@@ -152,8 +160,10 @@ func signedTxFunc() (*types.Transaction, error) {
 				return nil, err
 			}
 			txcache.Add(signedTx.Hash().Hex(), t.sender.Hex())
-			tranArr = append(tranArr, signedTx)
 			atomic.AddInt32(&batchSignCount, 1)
+			signTranArr.mux.Lock()
+			defer signTranArr.mux.Unlock()
+			signTranArr.TranArr = append(signTranArr.TranArr, signedTx)
 		}
 	}
 }