* :zap: Improve miningpool blockUpdater()
* :fire: Clean up
)
const (
- blockUpdateMS = 1000
maxSubmitChSize = 50
)
txPool: txPool,
newBlockCh: newBlockCh,
}
+ m.generateBlock()
go m.blockUpdater()
return m
}
// blockUpdater is the goroutine for keep update mining block
func (m *MiningPool) blockUpdater() {
- ticker := time.NewTicker(time.Millisecond * blockUpdateMS)
for {
select {
- case <-ticker.C:
+ case <-m.chain.BlockWaiter(m.chain.BestBlockHeight() + 1):
m.generateBlock()
case submitMsg := <-m.submitCh: