log.error("Thread #" + rank + ": queue was closed");
System.err.println("Thread #" + rank + ": queue was closed");
        public void run() {            try {                retval=(Long)queue.remove();                // System.out.println("Thread #" + rank + " removed element (" + retval + ")");            }            catch(QueueClosedException closed) {                log.error("Thread #" + rank + ": queue was closed");            }        }