(final Runnable r, final int batchSize)
| 75 | } |
| 76 | |
| 77 | private final void submit(final Runnable r, final int batchSize) { |
| 78 | syncPermits = batchSize; |
| 79 | tasks = new ArrayList<>(1); |
| 80 | tasks.add(r); |
| 81 | if (!running) { |
| 82 | run(); |
| 83 | syncPermits = 0; |
| 84 | } |
| 85 | } |
| 86 | |
| 87 | private final void run() { |
| 88 | running = true; |