diff --git a/go.mod b/go.mod index 298ba9b..b3c4a21 100644 --- a/go.mod +++ b/go.mod @@ -1,9 +1,9 @@ module github.com/frostbyte73/core -go 1.19 +go 1.22.1 require ( - github.com/gammazero/deque v0.2.1 + github.com/gammazero/deque v1.0.0 github.com/stretchr/testify v1.8.1 ) diff --git a/go.sum b/go.sum index 7c31a93..e252e20 100644 --- a/go.sum +++ b/go.sum @@ -1,8 +1,8 @@ github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/gammazero/deque v0.2.1 h1:qSdsbG6pgp6nL7A0+K/B7s12mcCY/5l5SIUpMOl+dC0= -github.com/gammazero/deque v0.2.1/go.mod h1:LFroj8x4cMYCukHJDbxFCkT+r9AndaJnFMuZDV34tuU= +github.com/gammazero/deque v1.0.0 h1:LTmimT8H7bXkkCy6gZX7zNLtkbz4NdS2z8LZuor3j34= +github.com/gammazero/deque v1.0.0/go.mod h1:iflpYvtGfM3U8S8j+sZEKIak3SAKYpA5/SQewgfXDKo= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= diff --git a/pool.go b/pool.go index 190943c..a1cdded 100644 --- a/pool.go +++ b/pool.go @@ -118,7 +118,7 @@ type worker struct { active bool next chan func() - deque *deque.Deque[func()] + deque deque.Deque[func()] draining Fuse done Fuse kill Fuse @@ -132,8 +132,8 @@ func NewQueueWorker(params QueueWorkerParams) QueueWorker { w := &worker{ QueueWorkerParams: params, next: make(chan func(), 1), - deque: deque.New[func()](params.QueueSize), } + w.deque.SetBaseCap(params.QueueSize) go w.run() return w }