(WorkerPool vWorkerPool, CairoEngine engine, int sharedQueryWorkerCount)
| 546 | } |
| 547 | |
| 548 | protected void setupViewJobs(WorkerPool vWorkerPool, CairoEngine engine, int sharedQueryWorkerCount) { |
| 549 | for (int i = 0, workerCount = vWorkerPool.getWorkerCount(); i < workerCount; i++) { |
| 550 | // create job per worker |
| 551 | final ViewCompilerJob viewCompilerJob = new ViewCompilerJob(i, engine, sharedQueryWorkerCount); |
| 552 | vWorkerPool.assign(i, viewCompilerJob); |
| 553 | vWorkerPool.freeOnExit(viewCompilerJob); |
| 554 | } |
| 555 | } |
| 556 | |
| 557 | protected void setupWalApplyJob( |
| 558 | WorkerPool sharedPoolWrite, |
no test coverage detected