log.error("Thread #" + rank + ": queue was closed");
System.err.println("Thread #" + rank + ": queue was closed");
		public void run()		{			try			{				for (int i = 0; i < iteration; i++)				{					queue.add(new Long(rank));					// Util.sleepRandom(1);					// System.out.println("Thread #" + rank + " added element (" + rank + ")");				}			}			catch (QueueClosedException closed)			{				log.error("Thread #" + rank + ": queue was closed");			}		}