private void checkSafetyWithCacheState(final FileDistribution fileDistribution,
										   final Condition cacheStateCondition, int fileCount) {
		// noinspection SynchronizationOnLocalVariableOrMethodParameter
		synchronized (cacheStateCondition) {
			for (int i = 0; i < (10 * fileCount) && shouldEnable(fileDistribution); ++i) {
				cacheStateCondition.waitNoInterrruptException(500);
			}
		}
	}
Distribute files on agents.

@param listener listener
@param safe     safe mode
ngrinder-core/src/main/java/net/grinder/SingleConsole.java