Added consumer taking items.
Removed consumer signaling per thread.