org.infinispan.persistence.util

Class PersistenceManagerCloseableSupplier<K,V>

java.lang.Object

org.infinispan.persistence.util.PersistenceManagerCloseableSupplier<K,V>

All Implemented Interfaces:

AutoCloseable, Supplier<CacheEntry<K,V>>, CloseableSupplier<CacheEntry<K,V>>

public class PersistenceManagerCloseableSupplier<K,V>
extends Object
implements CloseableSupplier<CacheEntry<K,V>>

A closeable supplier that provides a way to supply cache entries from a given persistence manager. On the first call to get this class will submit a task to collect all of the entries from the loader (or optionally a subset provided a given KeyFilter). A timeout value is required so that if a get blocks for the given timeout it will throw a TimeoutException.

Since:

8.0

Author:

William Burns

Constructor Summary

Constructors

Constructor and Description
PersistenceManagerCloseableSupplier(Executor executor, PersistenceManager manager, InternalEntryFactory factory, KeyFilter<K> filter, long timeout, TimeUnit unit, int maxQueue)

Method Summary

Modifier and Type	Method and Description
void	close()
CacheEntry<K,V>	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceManagerCloseableSupplier

public PersistenceManagerCloseableSupplier(Executor executor,
                                           PersistenceManager manager,
                                           InternalEntryFactory factory,
                                           KeyFilter<K> filter,
                                           long timeout,
                                           TimeUnit unit,
                                           int maxQueue)

Method Detail

get

public CacheEntry<K,V> get()
                    throws TimeoutException

Specified by:

get in interface Supplier<CacheEntry<K,V>>

Throws:

TimeoutException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableSupplier<CacheEntry<K,V>>