sequence::each.par: restructure to avoid edge case where concurrency limit was not being observed