org.apache.flink.core.fs

Class CloseableRegistry

java.lang.Object

org.apache.flink.util.AbstractCloseableRegistry<Closeable,Object>

org.apache.flink.core.fs.CloseableRegistry

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public class CloseableRegistry
extends AbstractCloseableRegistry<Closeable,Object>

This class allows to register instances of Closeable, which are all closed if this registry is closed.

Registering to an already closed registry will throw an exception and close the provided Closeable

All methods in this class are thread-safe.

This class closes all registered Closeables in the reverse registration order.

Field Summary

Fields inherited from class org.apache.flink.util.AbstractCloseableRegistry

closeableToRef

Constructor Summary

Constructors

Constructor and Description
CloseableRegistry()

Method Summary

Modifier and Type	Method and Description
protected void	doRegister(Closeable closeable, Map<Closeable,Object> closeableMap) Does the actual registration of the closeable with the registry map.
protected boolean	doUnRegister(Closeable closeable, Map<Closeable,Object> closeableMap) Does the actual un-registration of the closeable from the registry map.
protected Collection<Closeable>	getReferencesToClose()

Methods inherited from class org.apache.flink.util.AbstractCloseableRegistry

addCloseableInternal, close, getNumberOfRegisteredCloseables, getSynchronizationLock, isCloseableRegistered, isClosed, registerCloseable, removeCloseableInternal, unregisterCloseable

Methods inherited from class java.lang.Object

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

Constructor Detail

CloseableRegistry

public CloseableRegistry()

Method Detail

doRegister

protected void doRegister(@Nonnull
                          Closeable closeable,
                          @Nonnull
                          Map<Closeable,Object> closeableMap)

Description copied from class: AbstractCloseableRegistry

Does the actual registration of the closeable with the registry map. This should not do any long running or potentially blocking operations as is is executed under the registry's lock.

Specified by:

doRegister in class AbstractCloseableRegistry<Closeable,Object>

doUnRegister

protected boolean doUnRegister(@Nonnull
                               Closeable closeable,
                               @Nonnull
                               Map<Closeable,Object> closeableMap)

Description copied from class: AbstractCloseableRegistry

Does the actual un-registration of the closeable from the registry map. This should not do any long running or potentially blocking operations as is is executed under the registry's lock.

Specified by:

doUnRegister in class AbstractCloseableRegistry<Closeable,Object>

getReferencesToClose

protected Collection<Closeable> getReferencesToClose()

Overrides:

getReferencesToClose in class AbstractCloseableRegistry<Closeable,Object>