log.error("QueueTest.Reader.run(): exception=" + t);
System.err.println("QueueTest.Reader.run(): exception=" + t);
        public void run() {            Long el;            while(running) {                try {                    el=(Long)queue.remove();                    if(el == null) { // @remove                        System.out.println("QueueTest.Reader.run(): peek() returned null element. " +                                "queue.size()=" + queue.size() + ", queue.closed()=" + queue.closed());                    }                    assertNotNull(el);                    num_reads++;                }                catch(QueueClosedException closed) {                    running=false;                }                catch(Throwable t) {                    log.error("QueueTest.Reader.run(): exception=" + t);                }            }            reads[rank]=num_reads;        }