zgo

zq/zq.go

@@ -72,6 +72,13 @@ func (q *ZQ) AddJob(a any) *ZQ {
 	return q
 }
 
+func (q *ZQ) AddJobSync(a any) *ZQ {
+	q.JobsWg.Inc()
+	q.jobs <- a
+
+	return q
+}
+
 func (q *ZQ) Wait() {
 	q.JobsWg.Wait()
 }