org.apache.flink.core.fs

Class AutoCloseableRegistry

java.lang.Object

org.apache.flink.util.AbstractAutoCloseableRegistry<AutoCloseable,AutoCloseable,Object,Exception>

org.apache.flink.core.fs.AutoCloseableRegistry

All Implemented Interfaces:

AutoCloseable

@ThreadSafe
 @Internal
public class AutoCloseableRegistry
extends AbstractAutoCloseableRegistry<AutoCloseable,AutoCloseable,Object,Exception>

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

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

Unlike CloseableRegistry this class can throw an exception during the close.

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

Field Summary

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

closeableToRef

Constructor Summary

Constructors

Constructor and Description
AutoCloseableRegistry()

Method Summary

Modifier and Type	Method and Description
protected void	doClose(List<AutoCloseable> toClose) This implementation implies that any exception is possible during closing.
protected void	doRegister(AutoCloseable closeable, Map<AutoCloseable,Object> closeableMap) Does the actual registration of the closeable with the registry map.
protected boolean	doUnRegister(AutoCloseable closeable, Map<AutoCloseable,Object> closeableMap) Does the actual un-registration of the closeable from the registry map.

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

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

AutoCloseableRegistry

public AutoCloseableRegistry()

Method Detail

doRegister

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

Description copied from class: AbstractAutoCloseableRegistry

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 AbstractAutoCloseableRegistry<AutoCloseable,AutoCloseable,Object,Exception>

doUnRegister

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

Description copied from class: AbstractAutoCloseableRegistry

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 AbstractAutoCloseableRegistry<AutoCloseable,AutoCloseable,Object,Exception>

doClose

protected void doClose(List<AutoCloseable> toClose)
                throws Exception

This implementation implies that any exception is possible during closing.

Specified by:

doClose in class AbstractAutoCloseableRegistry<AutoCloseable,AutoCloseable,Object,Exception>

Throws:

Exception