Package com.github.tonivade.purefun.concurrent

Class CancellableImpl

java.lang.Object

com.github.tonivade.purefun.concurrent.CancellableImpl

All Implemented Interfaces:

Cancellable

final class CancellableImpl
extends Object
implements Cancellable

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	cancelled
private final ReentrantLock	lock
private final Promise<?>	promise
private Thread	thread

Constructor Summary

Constructors

Constructor	Description
CancellableImpl(Promise<?> promise)

Method Summary

Modifier and Type	Method	Description
void	cancel(boolean mayThreadInterrupted)
private void	interrupt()
boolean	isCancelled()
void	updateThread()

Methods inherited from class java.lang.Object

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

Field Details

lock

private final ReentrantLock lock

cancelled

private boolean cancelled

thread

@Nullable
private Thread thread

promise

private final Promise<?> promise

Constructor Details

CancellableImpl

public CancellableImpl(Promise<?> promise)

Method Details

updateThread

public void updateThread()

Specified by:

updateThread in interface Cancellable

cancel

public void cancel(boolean mayThreadInterrupted)

Specified by:

cancel in interface Cancellable

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Cancellable

interrupt

private void interrupt()