break;</BUG>
if( Job.cancelled(job) )
break;
<BUG>if( b != null ) {
try {
b.await();
_resume.await();
} catch( Exception e ) {
throw new RuntimeException(e);
}
}</BUG>
trainer.step();

_trainers[t] = new Base(clones);
final Base trainer = _trainers[t];
_threads[t] = new Thread("H2O Trainer " + t) {
@Override public void run() {
for( long i = 0; _stepsPerThread == 0 || i < _stepsPerThread; i++ ) {
if( Job.cancelled(job) )
break;
trainer.step();
