Skip navigation links

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


com.tangosol.io
Class AsyncBinaryStoreManager

java.lang.Object
  extended by com.tangosol.io.AsyncBinaryStoreManager

All Implemented Interfaces:
BinaryStoreManager

public class AsyncBinaryStoreManager
extends java.lang.Object
implements BinaryStoreManager

An AsyncBinaryStoreManager is a wrapper BinaryStoreManager that creates wrapper AsyncBinaryStore objects. An AsyncBinaryStore is a BinaryStore wrapper that performs the "O" portion of its I/O asynchronously (on a daemon thread.) Since the "O" portion is passed along to the wrapped BinaryStore on a separate thread, only read operations are blocking, thus the BinaryStore operations on a whole appear much faster. (It is somewhat analogous to a write-behind cache.)

In order for the AsyncBinaryStore objects to be used in situations that require a BinaryStoreManager, this class provides a manager for the AsyncBinaryStore objects, but to create the BinaryStore objects that will be wrapped by the AsyncBinaryStore objects, this AsyncBinaryStoreManager class has to be provided with an underlying BinaryStoreManager to wrap.

Since:
Coherence 2.5
Author:
cp 2004.06.18

Constructor Summary
AsyncBinaryStoreManager(BinaryStoreManager manager)
          Construct an AsyncBinaryStoreManager.
AsyncBinaryStoreManager(BinaryStoreManager manager, int cbMax)
          Construct an AsyncBinaryStoreManager.

 

Method Summary
 BinaryStore createBinaryStore()
          Factory method: Returns a new BinaryStore.
 void destroyBinaryStore(BinaryStore store)
          Lifecycle method: Destroy a BinaryStore previously created by this manager.
protected  BinaryStoreManager getBinaryStoreManager()
           
protected  java.util.Map getBinaryStoreMap()
           
protected  int getQueuedLimit()
           
protected  AsyncBinaryStore instantiateAsyncBinaryStore(BinaryStore store)
          Factory method: Instantiate an AsyncBinaryStore.

 

Constructor Detail

AsyncBinaryStoreManager

public AsyncBinaryStoreManager(BinaryStoreManager manager)
Construct an AsyncBinaryStoreManager. An AsyncBinaryStoreManager creates and destroys AsyncBinaryStore objects, which wrap other BinaryStore objects to provide asynchronous write operations.
Parameters:
manager - the BinaryStoreManager to wrap

AsyncBinaryStoreManager

public AsyncBinaryStoreManager(BinaryStoreManager manager,
                               int cbMax)
Construct an AsyncBinaryStoreManager. An AsyncBinaryStoreManager creates and destroys AsyncBinaryStore objects, which wrap other BinaryStore objects to provide asynchronous write operations.
Parameters:
manager - the BinaryStoreManager to wrap
cbMax - the maximum number of bytes to queue before blocking

Method Detail

createBinaryStore

public BinaryStore createBinaryStore()
Factory method: Returns a new BinaryStore.
Specified by:
createBinaryStore in interface BinaryStoreManager
Returns:
a new BinaryStore object

destroyBinaryStore

public void destroyBinaryStore(BinaryStore store)
Lifecycle method: Destroy a BinaryStore previously created by this manager.
Specified by:
destroyBinaryStore in interface BinaryStoreManager
Parameters:
store - a BinaryStore object previously created by this manager

getBinaryStoreManager

protected BinaryStoreManager getBinaryStoreManager()
Returns:
the wrapped BinaryStoreManager

getBinaryStoreMap

protected java.util.Map getBinaryStoreMap()
Returns:
the map of created AsyncBinaryStore objects and their corresponding wrapped BinaryStore objects

getQueuedLimit

protected int getQueuedLimit()
Returns:
the maximum number of pending bytes to allow to accumulate for async I/O in each of the AsyncBinaryStore objects created by this manager

instantiateAsyncBinaryStore

protected AsyncBinaryStore instantiateAsyncBinaryStore(BinaryStore store)
Factory method: Instantiate an AsyncBinaryStore.
Returns:
a new AsyncBinaryStore

Skip navigation links

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.