@Override
        public void run() {
            while (!Thread.currentThread().isInterrupted() && counter > 0) {
                assertNull("Duplicate found!", results.put(cgp.next(), null));
                --counter;
            }
        }