Implemented queue level concurrency limit (relates to #17).