Package com.killcoding.cache

Class CacheArray

java.lang.Object

com.killcoding.cache.CacheArray

All Implemented Interfaces:

Serializable

public class CacheArray
extends Object
implements Serializable

This class use asynchronous caching to handle large result and large list. Need class CacheArrayFilter to use.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private static ExecutorService	arrayPool
protected final List	BATCH
protected Integer	BATCH_INDEX
private final List<String>	cacheKeys	All cache keys list
private boolean	completed	'true' is completed
private CacheArrayFilter	filter
private static boolean	forceStop
protected Integer	INDEX
protected Object	lastItem
private static Integer	MAX_POOL_SIZE
private boolean	nullIsCompleted
protected Object	OBJECT
protected Integer	SIZE
private static boolean	stop
private static Integer	USING_POOL_SIZE

Constructor Summary

Constructors

Constructor	Description
CacheArray()	New a CacheArray object
CacheArray(boolean nullIsCompleted)

Method Summary

Modifier and Type	Method	Description
String	add(Object value)	Add object to the cache list
String	add(Object value, long sleepMs)	Add object to the cache list
void	addAll(List list)	Add list to the cache list
CacheArrayFilter	filter(long timer, long loopTimer, Runnable executeRun, Runnable executeBatchRun, Runnable completedRun, Runnable terminatedRun)
CacheArrayFilter	filter(long timer, Runnable executeRun, Runnable completedRun, Runnable terminatedRun)
void	filter(CacheArrayFilter _filter)	Need override the method to process logic handle
static void	forceStop()
void	forceTerminate()
Object	get(int index)	Get cache value by index
Object	getBatch()
Integer	getBatchIndex()
String	getCacheKey(int index)	Get cache key by index
List<String>	getCacheKeys()	Get all cache keys
Integer	getIndex()
static Integer	getMaxPoolSize()
Object	getObject()
Integer	getSize()
static double	getUsage()
static Integer	getUsingPoolSize()
static void	initPool(int poolSize)
Boolean	isCompleted()	Check complete status
static Boolean	isForceStoped()
Boolean	isForceTerminated()
boolean	isNulIsCompleted()
static Boolean	isStoped()
Boolean	isTerminated()
String	remove(int index)	Remove cache list index object
void	removeAll()	Remove all cache list
void	setNulIsCompleted(boolean nullIsCompleted)
private static Integer	setUsingPoolSize(int value)
int	size()	Get all cache size
static void	start()
static void	stop()
void	terminate()

Methods inherited from class java.lang.Object

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

Field Details

MAX_POOL_SIZE

private static Integer MAX_POOL_SIZE

USING_POOL_SIZE

private static Integer USING_POOL_SIZE

arrayPool

private static ExecutorService arrayPool

lastItem

protected Object lastItem

stop

private static boolean stop

forceStop

private static boolean forceStop

filter

private CacheArrayFilter filter

nullIsCompleted

private boolean nullIsCompleted

INDEX

protected Integer INDEX

SIZE

protected Integer SIZE

OBJECT

protected Object OBJECT

BATCH_INDEX

protected Integer BATCH_INDEX

BATCH

protected final List BATCH

cacheKeys

private final List<String> cacheKeys

All cache keys list

completed

private boolean completed

'true' is completed

Constructor Details

CacheArray

public CacheArray()

New a CacheArray object

CacheArray

public CacheArray(boolean nullIsCompleted)

Method Details

initPool

public static void initPool(int poolSize)

filter

public CacheArrayFilter filter(long timer,
 Runnable executeRun,
 Runnable completedRun,
 Runnable terminatedRun)

filter

public CacheArrayFilter filter(long timer,
 long loopTimer,
 Runnable executeRun,
 Runnable executeBatchRun,
 Runnable completedRun,
 Runnable terminatedRun)

filter

public void filter(CacheArrayFilter _filter)

Need override the method to process logic handle

Parameters:

filter - - CacheArrayFilter

getCacheKeys

public List<String> getCacheKeys()

Get all cache keys

Returns:

List

size

public int size()

Get all cache size

add

public String add(Object value)

Add object to the cache list

Returns:

- return cacke key

add

public String add(Object value,
 long sleepMs)
           throws InterruptedException

Add object to the cache list

Returns:

- return cacke key

Throws:

InterruptedException

addAll

public void addAll(List list)

Add list to the cache list

Parameters:

list - - It is object list value

remove

public String remove(int index)

Remove cache list index object

Parameters:

index - - It is remove index cache

Returns:

- return removed cache key name

removeAll

public void removeAll()

Remove all cache list

get

public Object get(int index)

Get cache value by index

Parameters:

index - - Cache index

Returns:

- Cache value

getCacheKey

public String getCacheKey(int index)

Get cache key by index

Parameters:

index - - Cache index

Returns:

- Cache key

isCompleted

public Boolean isCompleted()

Check complete status

Returns:

- 'true' is completed

isStoped

public static Boolean isStoped()

isForceStoped

public static Boolean isForceStoped()

stop

public static void stop()

forceStop

public static void forceStop()

start

public static void start()

terminate

public void terminate()

forceTerminate

public void forceTerminate()

isTerminated

public Boolean isTerminated()

isForceTerminated

public Boolean isForceTerminated()

getIndex

public Integer getIndex()

getSize

public Integer getSize()

getObject

public Object getObject()

getBatch

public Object getBatch()

getBatchIndex

public Integer getBatchIndex()

setUsingPoolSize

private static Integer setUsingPoolSize(int value)

getUsingPoolSize

public static Integer getUsingPoolSize()

getMaxPoolSize

public static Integer getMaxPoolSize()

getUsage

public static double getUsage()

isNulIsCompleted

public boolean isNulIsCompleted()

setNulIsCompleted

public void setNulIsCompleted(boolean nullIsCompleted)