for (int i = 0; i < NUM_DATABASE_WORK_EXECUTORS; i++) {
TransactionRegistry txs = new TransactionRegistry(database);
ThreadTransactionManagement txManage = new ThreadTransactionManagement(txs);
DatabaseWorkPipeline worker = new DatabaseWorkPipeline(database, txs, txManage, exceptionHandler);
workers[i] = worker;
worker.start();
}
}
private void stopWorker(DatabaseWorkPipeline worker) {
try {