log.error(ex);
System.err.println(ex);
    public void testBarrier() {        RemoveOneItem[] removers=new RemoveOneItem[10];        int num_dead=0;        for(int i=0; i < removers.length; i++) {            removers[i]=new RemoveOneItem(i);            removers[i].start();        }        Util.sleep(1000);        System.out.println("-- adding element 99");        try {            queue.add(new Long(99));        }        catch(Exception ex) {            log.error(ex);        }        Util.sleep(5000);        System.out.println("-- adding element 100");        try {            queue.add(new Long(100));        }        catch(Exception ex) {            log.error(ex);        }        Util.sleep(1000);        for(int i=0; i < removers.length; i++) {            System.out.println("remover #" + i + " is " + (removers[i].isAlive() ? "alive" : "terminated"));            if(!removers[i].isAlive()) {                num_dead++;            }        }        assertEquals(num_dead, 2);    }