ForkJoin

소스:

https://github.com/julyinsung/thisandthat/tree/master/src/main/java/parallel/example

참고:

http://www.popit.kr/java8-stream%EC%9D%98-parallel-%EC%B2%98%EB%A6%AC/

http://blog.naver.com/PostView.nhn?blogId=2feelus&logNo=220732310413

http://homes.cs.washington.edu/~djg/teachingMaterials/grossmanSPAC_forkJoinFramework.html

환경:

gradle, java1.8

개요:

ForkJoin라이브러리를 사용한 예제 구현.

설명:

1. 통상적인 예제는 int 배열의 숫자를 sum하는 것이나 여기서는 String List에서 다른 문장이 있는지 없는지를 체크(다른 아이디가 있는지를 체크)하는 예제로 수정.  

2. 사용법은 RecursiveTask<V>를 상속받아서 compute()를 구현한다.

compute()메소드의 구조는 설정한 SEQUENTIAL_THRESHOLD 이하인 경우는 로직을 수행하고 넘으면 다시 재귀호출을 하고 결과를 리턴한다.

public class ForkJoinSample extends RecursiveTask {

 static final int SEQUENTIAL_THRESHOLD = 500000; // 충분히 작은 단위는 여기서 5로 정했다.
             // 정하기 나름.


 public ForkJoinSample(List arr, int lo, int hi) {
    ....
 }

 @Override
 protected Boolean compute() {
  if (high - low <= SEQUENTIAL_THRESHOLD) { // 충분히 작은 배열 구간이면 값을 계산해 리턴한다.
   boolean result = true;

     // 수행로직...

   return result;

  } else {
   // 배열이 기준보다 크다면 divede and conquer방식으로 적당히 둘이상의 객체로 나누고,
   // 현재 쓰레드에서 처리할 객체는 compute를 호출해 값을 계산하고, fork할 객체는 join하여 값을 기다린후
   // 얻는다.
   int mid = low + (high - low) / 2;

   ForkJoinSample left = new ForkJoinSample(array, low, mid);
   ForkJoinSample right = new ForkJoinSample(array, mid, high);
   left.fork();
   Boolean rightAns = right.compute();
   Boolean leftAns = left.join();

   if (rightAns && leftAns) {
    return true;
   } else {
    return false;
   }
  }
 }

3. pool의 갯수는 commonPool()을 이용하여 자동으로 설정할수 있고 ForkJoinPool생성시 갯수를 지정 할 수 있다.

static Boolean read(List readAllLines) {
  // ForkJoinPool의 시작전과 후의 thread pool size를 비교한다.
  int beforeSize = ForkJoinPool.commonPool().getPoolSize();
  System.out.println("ForkJoin commonPool beforeSize=" + beforeSize);

  // common pool: 자동으로 pool갯수를 정해준다.
  boolean result = ForkJoinPool.commonPool().invoke(
    new ForkJoinSample(readAllLines, 0, readAllLines.size()));

  // custom pool: pool 갯수를 임의로 정할 수 있다.
  // ForkJoinPool myPool = new ForkJoinPool(3);
  // boolean result = myPool.invoke(new ForkJoinSample(readAllLines, 0,
  // readAllLines.size()));

  int afterSize = ForkJoinPool.commonPool().getPoolSize();
  System.out.println("ForkJoin commonPool afterSize=" + afterSize);
  return result;
 }