package main

import (
	"context"
	"log"
	"time"

	"github.com/k0kubun/pp"
	"github.com/mongodb/amboy"
	"github.com/mongodb/amboy/job"
	"github.com/mongodb/amboy/queue"
)

func main() {
	q := queue.NewLocalOrdered(1)
	//r := pool.NewLocalWorkers(2, q)
	//q.SetRunner(r)

	j := job.NewShellJob("sleep 2", "me")
	err := q.Put(j)
	if err != nil {
		log.Fatal(err)
	}
	o := job.NewShellJob("sleep 2", "me")
	err = q.Put(o)
	if err != nil {
		log.Fatal(err)
	}
	ctx := context.Background()
	err = q.Start(ctx)
	if err != nil {
		log.Fatal(err)
	}
	pp.Println(q.Stats())
	for stat := range q.JobStats(ctx) {
		pp.Println(stat)
	}
	amboy.WaitCtxInterval(ctx, q, 250*time.Millisecond)
	pp.Println(q.Stats())
}