Throttle based on queueing

[JulianBirch]

Just a suggestion, in erlang the cost of writing to a channel is directly linked to the number of unprocessed messages the channel has. So at low-bandwidth times there's no throttling, but when things are busy the producer threads get slowed down. You might like to add something in that vein.