parallel bloom calculation

core/receipt_processor.go

@@ -27,9 +27,9 @@ func (p *ReceiptBloomGenerator) Apply(receipt *types.Receipt) {
 	receipt.Bloom = types.CreateBloom(types.Receipts{receipt})
 }
 
-func NewAsyncReceiptBloomGenerator(length, workerSize int) *AsyncReceiptBloomGenerator {
+func NewAsyncReceiptBloomGenerator(txNums, workerSize int) *AsyncReceiptBloomGenerator {
 	generator := &AsyncReceiptBloomGenerator{
-		receipts: make(chan *types.Receipt, length),
+		receipts: make(chan *types.Receipt, txNums),
 		wg:       sync.WaitGroup{},
 	}
 	generator.startWorker(workerSize)

core/state_processor.go

@@ -396,7 +396,7 @@ func (p *StateProcessor) Process(block *types.Block, statedb *state.StateDB, cfg
 	commonTxs := make([]*types.Transaction, 0, txNum)
 
 	// initilise bloom processors
-	bloomProcessors := NewAsyncReceiptBloomGenerator(txNum, gopool.Threads(txNum))
+	bloomProcessors := NewAsyncReceiptBloomGenerator(txNum, gopool.Threads(1))
 
 	// usually do have two tx, one for validator set contract, another for system reward contract.
 	systemTxs := make([]*types.Transaction, 0, 2)

miner/worker.go

@@ -772,7 +772,7 @@ func (w *worker) commitTransactions(txs *types.TransactionsByPriceAndNonce, coin
 	}
 
 	// initilise bloom processors
-	bloomProcessors := core.NewAsyncReceiptBloomGenerator(txs.CurrentSize(), gopool.Threads(txs.CurrentSize()))
+	bloomProcessors := core.NewAsyncReceiptBloomGenerator(txs.CurrentSize(), gopool.Threads(1))
 
 LOOP:
 	for {