alluxio.concurrent

Class ForkJoinPoolHelper

java.lang.Object

alluxio.concurrent.ForkJoinPoolHelper

public class ForkJoinPoolHelper
extends Object

Provides helpers for working with ForkJoinPool.

Constructor Summary

Constructors

Constructor and Description
ForkJoinPoolHelper()

Method Summary

Modifier and Type	Method and Description
static void	safeManagedBlock(ForkJoinPool.ManagedBlocker blocker) Does managed blocking on ForkJoinPool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForkJoinPoolHelper

public ForkJoinPoolHelper()

Method Detail

safeManagedBlock

public static void safeManagedBlock(ForkJoinPool.ManagedBlocker blocker)
                             throws InterruptedException

Does managed blocking on ForkJoinPool. This helper is guaranteed to block even when ForkJoinPool is running on full capacity.

Parameters:

blocker - managed blocker resource

Throws:

InterruptedException