io.zonky.test.db.provider.common

Class PrefetchingDatabaseProvider.PrefetchingTask

java.lang.Object

java.util.concurrent.FutureTask<EmbeddedDatabase>

io.zonky.test.db.provider.common.PrefetchingDatabaseProvider.PrefetchingTask

All Implemented Interfaces:

java.lang.Comparable<PrefetchingDatabaseProvider.PrefetchingTask>, java.lang.Runnable, java.util.concurrent.Future<EmbeddedDatabase>, java.util.concurrent.RunnableFuture<EmbeddedDatabase>

Enclosing class:

PrefetchingDatabaseProvider

protected static class PrefetchingDatabaseProvider.PrefetchingTask
extends java.util.concurrent.FutureTask<EmbeddedDatabase>
implements java.lang.Comparable<PrefetchingDatabaseProvider.PrefetchingTask>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	PrefetchingDatabaseProvider.PrefetchingTask.TaskType

Field Summary

Fields

Modifier and Type	Field and Description
java.util.concurrent.Callable<EmbeddedDatabase>	action
PrefetchingDatabaseProvider.PipelineKey	key
int	priority
PrefetchingDatabaseProvider.PrefetchingTask.TaskType	type

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
int	compareTo(PrefetchingDatabaseProvider.PrefetchingTask task)
protected void	done()
static PrefetchingDatabaseProvider.PrefetchingTask	forPreparer(PrefetchingDatabaseProvider.PipelineKey key, DatabaseProvider provider, DatabasePreparer preparer, int priority)
static PrefetchingDatabaseProvider.PrefetchingTask	fromTask(PrefetchingDatabaseProvider.PipelineKey key, PrefetchingDatabaseProvider.PrefetchingTask task, int priority)
void	run()
static PrefetchingDatabaseProvider.PrefetchingTask	withDatabase(PrefetchingDatabaseProvider.PipelineKey key, EmbeddedDatabase database, DatabasePreparer preparer, int priority)
static PrefetchingDatabaseProvider.PrefetchingTask	withDatabase(PrefetchingDatabaseProvider.PipelineKey key, EmbeddedDatabase database, int priority)

Methods inherited from class java.util.concurrent.FutureTask

get, get, isCancelled, isDone, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Field Detail

key

public final PrefetchingDatabaseProvider.PipelineKey key

action

public final java.util.concurrent.Callable<EmbeddedDatabase> action

type

public final PrefetchingDatabaseProvider.PrefetchingTask.TaskType type

priority

public final int priority

Method Detail

forPreparer

public static PrefetchingDatabaseProvider.PrefetchingTask forPreparer(PrefetchingDatabaseProvider.PipelineKey key,
                                                                      DatabaseProvider provider,
                                                                      DatabasePreparer preparer,
                                                                      int priority)

withDatabase

public static PrefetchingDatabaseProvider.PrefetchingTask withDatabase(PrefetchingDatabaseProvider.PipelineKey key,
                                                                       EmbeddedDatabase database,
                                                                       DatabasePreparer preparer,
                                                                       int priority)

withDatabase

public static PrefetchingDatabaseProvider.PrefetchingTask withDatabase(PrefetchingDatabaseProvider.PipelineKey key,
                                                                       EmbeddedDatabase database,
                                                                       int priority)

fromTask

public static PrefetchingDatabaseProvider.PrefetchingTask fromTask(PrefetchingDatabaseProvider.PipelineKey key,
                                                                   PrefetchingDatabaseProvider.PrefetchingTask task,
                                                                   int priority)

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in interface java.util.concurrent.RunnableFuture<EmbeddedDatabase>

Overrides:

run in class java.util.concurrent.FutureTask<EmbeddedDatabase>

done

protected void done()

Overrides:

done in class java.util.concurrent.FutureTask<EmbeddedDatabase>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<EmbeddedDatabase>

Overrides:

cancel in class java.util.concurrent.FutureTask<EmbeddedDatabase>

compareTo

public int compareTo(PrefetchingDatabaseProvider.PrefetchingTask task)

Specified by:

compareTo in interface java.lang.Comparable<PrefetchingDatabaseProvider.PrefetchingTask>