comment typo fixed
This commit is contained in:
parent
ff562bea65
commit
fb246ee164
@ -169,7 +169,7 @@ class ParallelProcessor<T extends Runnable> {
|
|||||||
public
|
public
|
||||||
void doneQueueingTasks() throws InterruptedException {
|
void doneQueueingTasks() throws InterruptedException {
|
||||||
for (int i = 0; i < threads.size(); i++) {
|
for (int i = 0; i < threads.size(); i++) {
|
||||||
// this tells out threads that we have finished work and can exit
|
// this tells our threads that we have finished work and can exit
|
||||||
queue.put(SENTINEL);
|
queue.put(SENTINEL);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user