diff --git a/main.go b/main.go index afdb0e7..09385e1 100644 --- a/main.go +++ b/main.go @@ -112,8 +112,6 @@ func InitDatabase() (err error) { var JobPoolSize int = 5 var ConcurrencyLimit int = 1 var WorkerJobPool chan string -var GlobalWriteSemaphore common.Semaphore - var GlobalWriteLock sync.Mutex func main() { @@ -174,7 +172,6 @@ func main() { } } - GlobalWriteSemaphore = common.NewSemaphore(ConcurrencyLimit) wg := sync.WaitGroup{} for _, jobFile := range WorkerJobPool {