Added some logic to limit the number of heavy threads produced and used by the concurrent engine.