public final class CancellationManager extends Object implements Disposable
Constructor and Description |
---|
CancellationManager() |
CancellationManager(int cancelTimeoutMs,
int disposeTimeoutMs) |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancel all registered cancellation points;
|
void |
cancel(String theDatabaseName)
Cancel all registered cancellation points for the specific database.
|
int |
countCancellationPoint(String db) |
void |
dispose()
Dispose cancellation manager;
It cancels all active cancellation points and cleanup all resources;
|
<T> T |
executeExclusiveDatabaseOperation(String theDatabaseName,
String theProcessDescription,
Callable<T> theWorker)
Executes database-critical operation;
It acquires global lock in shared mode;
It acquires local per-db lock in exclusive mode;
|
void |
executeExclusiveDatabaseOperation(String theDatabaseName,
String theProcessDescription,
Runnable theWorker) |
<T> T |
executeSharedOperation(Callable<T> theWorker)
Executes critical operation;
It acquires global lock in shared mode;
|
CancellationPoint |
registerCancellationPoint(String theCancellationMessage,
String theDatabaseName)
Register cancellation point with default thrower;
|
CancellationPoint |
registerCancellationPoint(String theCancellationMessage,
String theDatabaseName,
Function<String,? extends RuntimeException> theCancellationThrower)
This method is used to register new cancellation point;
|
void |
registerDatabase(String theDatabaseName)
Register database in the system;
|
void |
unregisterDatabase(String theDatabaseName)
De-register database;
|
public CancellationManager()
public CancellationManager(int cancelTimeoutMs, int disposeTimeoutMs)
public CancellationPoint registerCancellationPoint(String theCancellationMessage, String theDatabaseName)
theCancellationMessage
- - the cancellation message;theDatabaseName
- - the database name;public CancellationPoint registerCancellationPoint(String theCancellationMessage, String theDatabaseName, Function<String,? extends RuntimeException> theCancellationThrower)
theCancellationMessage
- - the new cancellation message;theDatabaseName
- - the database name;theCancellationThrower
- - the thrower which will be used;public void registerDatabase(String theDatabaseName)
theDatabaseName
- - the database name;public void unregisterDatabase(String theDatabaseName)
theDatabaseName
- - the database name;public <T> T executeSharedOperation(Callable<T> theWorker)
theWorker
- - the worked for execution;public void executeExclusiveDatabaseOperation(String theDatabaseName, String theProcessDescription, Runnable theWorker)
public <T> T executeExclusiveDatabaseOperation(String theDatabaseName, String theProcessDescription, Callable<T> theWorker)
theDatabaseName
- - the database name;theProcessDescription
- - the description of process;theWorker
- - the worked for execution;public void cancel()
public void cancel(String theDatabaseName)
theDatabaseName
- - the database's name;public void dispose()
dispose
in interface Disposable
public int countCancellationPoint(String db)
Copyright © 2010-2016 Stardog Union. All Rights Reserved.