KernelRunner.FJSafeBarrier

java.lang.Object

com.aparapi.internal.kernel.KernelRunner.FJSafeBarrier

All Implemented Interfaces:: IKernelBarrier, ForkJoinPool.ManagedBlocker

Enclosing class:: KernelRunner

private static final class KernelRunner.FJSafeBarrier extends Object implements IKernelBarrier

Field Summary

Fields

Modifier and Type

Field

Description

(package private) final AtomicBoolean

brokenBarrier

(package private) final AtomicBoolean

canceled

(package private) final Object

lock

(package private) int

remainingThreads

(package private) final int

threads
Constructor Summary

Constructors

Constructor

Description

FJSafeBarrier(int threads)
Method Summary

Modifier and Type

Method

Description

boolean

block()

void

breakBarrier(Throwable e)

Should be called by worker threads when a fatal exception occurs, so that all threads fail-fast and no deadlock occurs.

void

cancelBarrier()

Cancels the barrier.

boolean

isReleasable()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- threads
  
  final int threads
- brokenBarrier
  
  final AtomicBoolean brokenBarrier
- canceled
  
  final AtomicBoolean canceled
- lock
  
  final Object lock
- remainingThreads
  
  int remainingThreads
Constructor Details
- FJSafeBarrier
  
  FJSafeBarrier(int threads)
Method Details
- breakBarrier
  
  public void breakBarrier(Throwable e)
  
  Should be called by worker threads when a fatal exception occurs, so that all threads fail-fast and no deadlock occurs.
  
  Specified by:
  
  breakBarrier in interface IKernelBarrier
- cancelBarrier
  
  public void cancelBarrier()
  
  Description copied from interface: IKernelBarrier
  
  Cancels the barrier. All threads that may be waiting for the barrier are released and barrier is permanently disabled.
  
  Specified by:
  
  cancelBarrier in interface IKernelBarrier
- block
  
  public boolean block() throws InterruptedException
  
  Specified by:
  
  block in interface ForkJoinPool.ManagedBlocker
  
  Throws:
  
  InterruptedException
- isReleasable
  
  public boolean isReleasable()
  
  Specified by:
  
  isReleasable in interface ForkJoinPool.ManagedBlocker