hasNext method

hasNext.java

@Test
    public void correctValuesForConcurrentHasNext() throws ExecutionException, InterruptedException {

        int exceptionCount = 0;
        for (int i = 0; i <5000; i++) {
            Iterator<Integer> syncIterator = new SyncIterator<Integer>(
                Stream.iterate(0, j -> j + 1).limit(200)
                    .collect(toList())
                    .iterator());
            CountDownLatch startSignal = new CountDownLatch(1);
            ExecutorService executors = Executors.newFixedThreadPool(2);
            Future<Boolean> hasNext = executors.submit(() -> {
                startSignal.await();
                while (syncIterator.hasNext()) {
                    syncIterator.next();
                } return true;
            });
            Future<Boolean> hasNext2 = executors.submit(() -> {
                startSignal.await();
                while (syncIterator.hasNext()) {
                    syncIterator.next();
                } return true;
            });
            startSignal.countDown();
            try {
                MatcherAssert.assertThat(
                    "Error",
                    hasNext.get(),
                    Matchers.equalTo(hasNext2.get()));
            } catch (ExecutionException e) {
                exceptionCount++;
            }
        }
        System.out.println(exceptionCount);
    }