hu.akarnokd.reactive4java.util

Class RefCountCloseable

java.lang.Object

hu.akarnokd.reactive4java.util.RefCountCloseable

All Implemented Interfaces:

Cancelable, java.io.Closeable, java.lang.AutoCloseable

public class RefCountCloseable
extends java.lang.Object
implements java.io.Closeable, Cancelable

Represents a closeable resource that only allows closing when all dependent closeable objects have been closed.

Can be used in cases where one has to wait for all work items to complete before closing the main handle.

Since:

0.97

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	RefCountCloseable.InnerCloseable The dependent closeable implementation.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Closeable	closeable The closeable to close when all dependent closeables are closed.
protected int	count The number of open dependent closeables.
protected java.util.concurrent.locks.Lock	lock The lock guarding the internal variables.
protected boolean	primaryClosed Indicate that the primary handle is closed already.

Constructor Summary

Constructors

Constructor and Description
RefCountCloseable(java.io.Closeable closeable) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
java.io.Closeable	getCloseable() Returns a new dependent closeable instance.
boolean	isClosed()
protected void	release() Releases an dependent closeable.

Methods inherited from class java.lang.Object

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

Field Detail

lock

protected final java.util.concurrent.locks.Lock lock

The lock guarding the internal variables.

closeable

protected java.io.Closeable closeable

The closeable to close when all dependent closeables are closed.

primaryClosed

protected boolean primaryClosed

Indicate that the primary handle is closed already.

count

protected int count

The number of open dependent closeables.

Constructor Detail

RefCountCloseable

public RefCountCloseable(@Nonnull
                         java.io.Closeable closeable)

Constructor.

Parameters:

closeable - the closeable to manage

Method Detail

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Cancelable

Returns:

true if the object has been closed.

getCloseable

public java.io.Closeable getCloseable()

Returns a new dependent closeable instance. If all of these dependent closeables have been closed, the underlying closeable will be closed once.

Returns:

the closeable

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

release

protected void release()
                throws java.io.IOException

Releases an dependent closeable.

Throws:

java.io.IOException - the propagated close exception