zgo

zq/zq.go

@@ -62,12 +62,14 @@ func (q *ZQ) RemoveWorker() {
 	q.AddWorker(-1)
 }
 
-func (q *ZQ) AddJob(a any) {
+func (q *ZQ) AddJob(a any) *ZQ {
 	q.JobsWg.Inc()
 
 	go func() {
 		q.jobs <- a
 	}()
+
+	return q
 }
 
 func (q *ZQ) Wait() {

zquit/zquit.go

@@ -72,3 +72,7 @@ func (q *ZQuit) ZQuitMiddleware(c *gin.Context) {
 
 	c.Next()
 }
+
+func (q *ZQuit) Shutdown() {
+	q.isQuit = true
+}