Class LazyCleanerImpl.RefQueueBlocker<T>

java.lang.Object

org.postgresql.util.LazyCleanerImpl.RefQueueBlocker<T>

Type Parameters:

T - the type of the objects referenced by the References in the queue

All Implemented Interfaces:

ForkJoinPool.ManagedBlocker

Enclosing class:

LazyCleanerImpl

private static class LazyCleanerImpl.RefQueueBlocker<T>
extends Object
implements ForkJoinPool.ManagedBlocker

RefQueueBlocker retrieves references from the reference queue without blocking ForkJoinPool CPU threads.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	blockTimeoutMillis
private final ReferenceQueue<T>	queue
private Reference<? extends T>	ref
private final BooleanSupplier	shouldTerminate
private final String	threadName

Constructor Summary

Constructors

Constructor	Description
RefQueueBlocker(ReferenceQueue<T> queue, String threadName, Duration blockTimeout, BooleanSupplier shouldTerminate)

Method Summary

Modifier and Type	Method	Description
boolean	block()
(package private) Reference<? extends T>	drainOne()
boolean	isReleasable()

Methods inherited from class Object

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

Field Details

queue

private final ReferenceQueue<T> queue

threadName

private final String threadName

ref

private Reference<? extends T> ref

blockTimeoutMillis

private final long blockTimeoutMillis

shouldTerminate

private final BooleanSupplier shouldTerminate

Constructor Details

RefQueueBlocker

RefQueueBlocker(ReferenceQueue<T> queue,
 String threadName,
 Duration blockTimeout,
 BooleanSupplier shouldTerminate)

Method Details

isReleasable

public boolean isReleasable()

Specified by:

isReleasable in interface ForkJoinPool.ManagedBlocker

block

public boolean block()
              throws InterruptedException

Specified by:

block in interface ForkJoinPool.ManagedBlocker

Throws:

InterruptedException

drainOne

Reference<? extends T> drainOne()