change processing()
This commit is contained in:
parent
fdcea19863
commit
a3c9183aa8
@ -5,13 +5,15 @@ import java.util.Collection;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.concurrent.ForkJoinTask;
|
import java.util.concurrent.ForkJoinTask;
|
||||||
import java.util.concurrent.RecursiveAction;
|
import java.util.concurrent.RecursiveAction;
|
||||||
|
import java.util.logging.Logger;
|
||||||
|
|
||||||
public class CustomRecursiveAction extends RecursiveAction {
|
public class CustomRecursiveAction extends RecursiveAction {
|
||||||
|
|
||||||
private String workLoad = "";
|
private String workLoad = "";
|
||||||
|
|
||||||
private static final int THRESHOLD = 4;
|
private static final int THRESHOLD = 4;
|
||||||
|
|
||||||
|
private static Logger logger = Logger.getAnonymousLogger();
|
||||||
|
|
||||||
public CustomRecursiveAction(String workLoad) {
|
public CustomRecursiveAction(String workLoad) {
|
||||||
this.workLoad = workLoad;
|
this.workLoad = workLoad;
|
||||||
}
|
}
|
||||||
@ -41,6 +43,7 @@ public class CustomRecursiveAction extends RecursiveAction {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void processing(String work) {
|
private void processing(String work) {
|
||||||
work.toUpperCase();
|
String result = work.toUpperCase();
|
||||||
|
logger.info("This result - (" + result + ") - was processed by " + Thread.currentThread().getName());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user