From c4b38c56abd2dc46e6ad9b1d90ba25b944dd85d9 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Sun, 14 Jun 2020 22:23:07 +0800
Subject: [PATCH] update

---
 src/resource_pool.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/resource_pool.go b/src/resource_pool.go
index ddc1f86..0884ecd 100644
--- a/src/resource_pool.go
+++ b/src/resource_pool.go
@@ -704,9 +704,12 @@ func (pool *ResourcePool) acquireResource(job Job) []NodeStatus {
 	pool.batchJobs[job.Name] = job
 	pool.batchMu.Unlock()
 	for {
+		pool.batchMu.Lock()
 		if _, ok := pool.batchAllocations[job.Name]; ok {
+			pool.batchMu.Unlock()
 			break
 		} else {
+			pool.batchMu.Unlock()
 			time.Sleep(time.Millisecond * 100)
 		}
 	}