package queue

import (
	"sync"
	"time"
)

type RunCall struct {
	PopCount int
	Duration time.Duration
	Wait     func(dur time.Duration)
	Begin    func(count int) interface{}
	Process  func(be interface{}, data interface{})
}

func Run(c RunCall, lock sync.Locker, qu Queue) {
	var count int
	var popCount = c.PopCount
	if popCount <= 0 {
		popCount = 10
	}
	if c.Wait == nil {
		c.Wait = func(dur time.Duration) {
			time.Sleep(dur)
		}
	}
	ten := make([]interface{}, popCount)
	for {
		count = 0
		lock.Lock()
		for i := 0; i < popCount; i++ {
			v := qu.Pop()
			if v == nil {
				break
			}
			ten[i] = v
			count++
		}
		lock.Unlock()
		var bn = c.Begin(count)
		for i := 0; i < count; i++ {
			c.Process(bn, ten[i])
		}
		c.Wait(c.Duration)
	}
}