|
|
|
@ -112,8 +112,6 @@ func InitDatabase() (err error) {
|
|
|
|
var JobPoolSize int = 5
|
|
|
|
var JobPoolSize int = 5
|
|
|
|
var ConcurrencyLimit int = 1
|
|
|
|
var ConcurrencyLimit int = 1
|
|
|
|
var WorkerJobPool chan string
|
|
|
|
var WorkerJobPool chan string
|
|
|
|
var GlobalWriteSemaphore common.Semaphore
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var GlobalWriteLock sync.Mutex
|
|
|
|
var GlobalWriteLock sync.Mutex
|
|
|
|
|
|
|
|
|
|
|
|
func main() {
|
|
|
|
func main() {
|
|
|
|
@ -174,7 +172,6 @@ func main() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
GlobalWriteSemaphore = common.NewSemaphore(ConcurrencyLimit)
|
|
|
|
|
|
|
|
wg := sync.WaitGroup{}
|
|
|
|
wg := sync.WaitGroup{}
|
|
|
|
|
|
|
|
|
|
|
|
for _, jobFile := range WorkerJobPool {
|
|
|
|
for _, jobFile := range WorkerJobPool {
|
|
|
|
|
