sync: make Pool thread-safe

Make sure the object is locked when trying to modify it.
Binary size seems unaffected when not using threading.

1 files changed, 8 insertions, 0 deletions

diff --git a/src/sync/pool.go b/src/sync/pool.go
index 41f06a65c..5a29afebd 100644
--- a/src/sync/pool.go
+++ b/src/sync/pool.go
@@ -1,18 +1,24 @@
 package sync
 
+import "internal/task"
+
 // Pool is a very simple implementation of sync.Pool.
 type Pool struct {
+	lock  task.PMutex
 	New   func() interface{}
 	items []interface{}
 }
 
 // Get returns an item in the pool, or the value of calling Pool.New() if there are no items.
 func (p *Pool) Get() interface{} {
+	p.lock.Lock()
 	if len(p.items) > 0 {
 		x := p.items[len(p.items)-1]
 		p.items = p.items[:len(p.items)-1]
+		p.lock.Unlock()
 		return x
 	}
+	p.lock.Unlock()
 	if p.New == nil {
 		return nil
 	}
@@ -21,5 +27,7 @@ func (p *Pool) Get() interface{} {
 
 // Put adds a value back into the pool.
 func (p *Pool) Put(x interface{}) {
+	p.lock.Lock()
 	p.items = append(p.items, x)
+	p.lock.Unlock()
 }