mirror of
https://github.com/nxshock/gwp.git
synced 2024-11-27 03:31:02 +05:00
Add missed dependency from calculate ETA period
This commit is contained in:
parent
6bcb8d3356
commit
9ca94c6742
2
gwp.go
2
gwp.go
@ -52,7 +52,7 @@ func New(threadCount int) *WorkerPool {
|
|||||||
case <-tickerUpdateText.C:
|
case <-tickerUpdateText.C:
|
||||||
workerPool.printProgress()
|
workerPool.printProgress()
|
||||||
case <-tickerCalculateEta.C:
|
case <-tickerCalculateEta.C:
|
||||||
workerPool.currentSpeed = float64(workerPool.processedCount-prevPos) * float64(time.Second) / float64(time.Now().Sub(prevTime))
|
workerPool.currentSpeed = float64(workerPool.processedCount-prevPos) * float64(defaultCalculateEtaPeriod) / float64(time.Now().Sub(prevTime))
|
||||||
prevPos = workerPool.processedCount
|
prevPos = workerPool.processedCount
|
||||||
prevTime = time.Now()
|
prevTime = time.Now()
|
||||||
case err := <-workerPool.resultChan:
|
case err := <-workerPool.resultChan:
|
||||||
|
Loading…
Reference in New Issue
Block a user