log.error("Thread #" + rank + ": queue was closed");
System.err.println("Thread #" + rank + ": queue was closed");
		public void run()		{			boolean finished = false;			while (!finished)			{				try				{					retval = (Long) queue.remove(timeout);					// System.out.println("Thread #" + rank + " removed element (" + retval + ")");					finished = true;				}				catch (QueueClosedException closed)				{					log.error("Thread #" + rank + ": queue was closed");					finished = true;				}				catch (TimeoutException e)				{				}			}		}