log.error("QueueTest.Writer.run(): exception=" + t);
System.err.println("QueueTest.Writer.run(): exception=" + t);
        public void run() {            while(running) {                try {                    queue.add(new Long(System.currentTimeMillis()));                    num_writes++;                }                catch(QueueClosedException closed) {                    running=false;                }                catch(Throwable t) {                    log.error("QueueTest.Writer.run(): exception=" + t);                }            }            writes[rank]=num_writes;        }