@@ -329,11 +329,13 @@ [super dealloc]; } - (void)OF_dispatchJob: (OFThreadPoolJob*)job { - of_atomic_inc_int(&count); + [countCondition lock]; + count++; + [countCondition unlock]; [queueCondition lock]; @try { [queue appendObject: job]; [queueCondition signal];