Future-Instances 목록

Question

나는 Future-Instance 목록을 더 많은 성과물로 대체하고 싶습니다. 현재 트리를 탐색하고 Callable을 제출하여 트리의 각 노드에 대한 자손 또는 자체 노드 수를 확인합니다. 나는 목록에 미래 인스턴스를 저장하고 다음 번에 필요한 목록에서 해당 노드 수를 얻을 수있어 :

try { 
    assert mIndex + 1 < mDescendants.size(); 
    mItem = 
     Item.BUILDER.set(mAngle, mExtension, mIndexToParent).setParentDescendantCount(
       mParDescendantCount).setDescendantCount(mDescendants.get(mIndex + 1).get()).build(); 
} catch (final InterruptedException | ExecutionException e) { 
    LOGWRAPPER.error(e.getMessage(), e); 
} 

슬픈 일이 목록을 사용하고있다 축이 모든 미래까지 기다려야한다는 것이다 인스턴스가 제출되었습니다. 또한 주 메모리 한계를 넘어 확장 할 수 없습니다. -/

Google Guava 및 ListenableFuture가 올바른 사용법 일 수 있습니다.

편집 : 이제 Future가 실행될 때마다 미래가 목록에 추가되는 PropertyChangeListener로 실제로 무언가를 만들 것이라고 생각합니다. 그런 다음 CountDownLatch를 1로 초기화하고 목록에 새로운 Future가 추가 될 때마다 countDown()을 호출합니다. 뭔가 같이 : doHasNext에서 다음

/** 
* {@inheritDoc} 
*/ 
@Override 
public boolean hasNext() { 
    if (mDescendants.size() > 0) { 
     return doHasNext(); 
    } else { 
     try { 
      mLatch.await(5, TimeUnit.SECONDS); 
     } catch (final InterruptedException e) { 
      LOGWRAPPER.error(e.getMessage(), e); 
     } 
     return doHasNext(); 
    } 
} 

() :

try { 
    assert mIndex + 1 < mDescendants.size(); 
    mItem = 
     Item.BUILDER.set(mAngle, mExtension, mIndexToParent).setParentDescendantCount(
       mParDescendantCount).setDescendantCount(mDescendants.get(mIndex + 1).get()).build(); 
    mLatch = new CountDownLatch(1); 
} catch (final InterruptedException | ExecutionException e) { 
    LOGWRAPPER.error(e.getMessage(), e); 
} 

과 리스너 :

/** {@inheritDoc} */ 
@SuppressWarnings("unchecked") 
@Override 
public void propertyChange(final PropertyChangeEvent paramEvent) { 
    Objects.requireNonNull(paramEvent); 

    if ("descendants".equals(paramEvent.getPropertyName())) { 
     mDescendants.add((Future<Integer>) paramEvent.getNewValue()); 
     mLatch.countDown(); 
    } 
} 

나는, 너무 늦기 작동하는지 모르겠어요 그리고는 불신 방법은 위의 코드를 테스트하지 않은 CountDownLatch를 사용합니다.

편집 : 누군가가 관심이있는 경우를 위해서. CountDownLatch와 List 대신에 이제는 단순히 "깨끗한"솔루션 인 PropertyChangeListener 구현과 함께 BlockingQueue를 사용했습니다.

관련,

요하네스

Answer 1

당신이 단지 completion service를 사용할 수 있습니까? 일단 제출되면, 첫 번째 미래를 처리 할 것입니다 ...