joel/largeRCRF-Java
1
0
Fork 0
Code Issues 3 Pull requests Releases Wiki Activity

Change how parallel trees are trained to be more robust to Threads getting terminated.

Browse source 
This will hopefully make the package more stable on cluster systems, where sometimes the forests
immediately stall.
This commit is contained in:
Joel Therrien 2019-04-26 11:04:03 -07:00
parent 1e643385ee
commit de3de300cf
1 changed files with 15 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/main/java/ca/joeltherrien/randomforest/tree/ForestTrainer.java
View file

@ -34,6 +34,7 @@ import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@ -135,15 +136,15 @@ public class ForestTrainer<Y, TO, FO> {
executorService.execute(worker);
}
executorService.shutdown();
int prevNumberTreesSet = -1;
while(!executorService.isTerminated()){
while(true){
try {
Thread.sleep(500);
if (executorService.awaitTermination(5, TimeUnit.SECONDS)) break;
} catch (InterruptedException e) {
// do nothing; who cares?
System.err.println("There was an InterruptedException while waiting for the forest to finish training; this is unusual but on its own shouldn't be a problem.");
System.err.println("Please send a bug report about it to joelt@sfu.ca");
e.printStackTrace();
// do nothing; this shouldn't be an issue
}
if(displayProgress) {
@ -195,15 +196,15 @@ public class ForestTrainer<Y, TO, FO> {
executorService.execute(worker);
}
executorService.shutdown();
int prevNumberTreesSet = -1;
while(!executorService.isTerminated()){
while(true){
try {
Thread.sleep(100);
if (executorService.awaitTermination(5, TimeUnit.SECONDS)) break;
} catch (InterruptedException e) {
// do nothing; who cares?
System.err.println("There was an InterruptedException while waiting for the forest to finish training; this is unusual but on its own shouldn't be a problem.");
System.err.println("Please send a bug report about it to joelt@sfu.ca");
e.printStackTrace();
// do nothing; this shouldn't be an issue
}
if(displayProgress) {