Wait on Submit until queue has

[janekolszak]

Hi, I'm in a need of blocking Submit until the queue of tasks is small enough. I imagine something like SubmitBlock( ctx context.Context, minQueueDepth uint, f func()) that waits for the queue to be small enough, inserts the func and immediately returns.

Would you like to add something like that or accept a PR?

[toqueteos]

Here's the workaround I'm using until workerpool supports customizable queue size:

var stop bool
for !stop {
    if pool.WaitingQueueSize() > DESIRED_QUEUE_SIZE {
        time.Sleep(CUSTOM_DURATION) // exponential backoff would probably be better
        continue
    }
    pool.Submit(func() {
        // ...
    })
}