Uniqueness test

uniqueness_test.java

@Test
    public void testUniquenessInMultiThreadedScenario() throws Exception {

        final Long firstMember = 100L;
        
        final List<Exception> exceptionList = new ArrayList<Exception>();

        ExecutorService exec = Executors.newFixedThreadPool(16);
        for (int i = 101; i < 1000; i++) {
            final Long buddyId = new Long(i);
            exec.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        memberService.refer(firstMember, buddyId);
                    } catch (NoSuchElementException noSuchElementException) {
                        exceptionList.add(noSuchElementException);
                    }
                }
            }

            );
        }

        exec.shutdown();
        exec.awaitTermination(50, TimeUnit.SECONDS);
        
        assertTrue("Exceptions found when creating nodes", exceptionList.isEmpty());
        
    }