(WorkerPool mvWorkerPool, CairoEngine engine, int sharedQueryWorkerCount)
| 535 | } |
| 536 | |
| 537 | protected void setupMatViewJobs(WorkerPool mvWorkerPool, CairoEngine engine, int sharedQueryWorkerCount) { |
| 538 | for (int i = 0, workerCount = mvWorkerPool.getWorkerCount(); i < workerCount; i++) { |
| 539 | // create job per worker |
| 540 | final MatViewRefreshJob matViewRefreshJob = new MatViewRefreshJob(i, engine, sharedQueryWorkerCount); |
| 541 | mvWorkerPool.assign(i, matViewRefreshJob); |
| 542 | mvWorkerPool.freeOnExit(matViewRefreshJob); |
| 543 | } |
| 544 | final MatViewTimerJob matViewTimerJob = new MatViewTimerJob(engine); |
| 545 | mvWorkerPool.assign(matViewTimerJob); |
| 546 | } |
| 547 | |
| 548 | protected void setupViewJobs(WorkerPool vWorkerPool, CairoEngine engine, int sharedQueryWorkerCount) { |
| 549 | for (int i = 0, workerCount = vWorkerPool.getWorkerCount(); i < workerCount; i++) { |
no test coverage detected