log.error(ex);
System.err.println(ex);
	public void testMultipleWriterOneReader()	{		AddOneItem[] adders = new AddOneItem[10];		int num_dead = 0;		int num_items = 0;		int items = 1000;		for (int i = 0; i < adders.length; i++)		{			adders[i] = new AddOneItem(i, items);			adders[i].start();		}		while (num_items < (adders.length*items))		{			try			{				queue.remove();				num_items++;			}			catch (Exception ex)			{				log.error(ex);			}		}		Util.sleep(1000);		for (int i = 0; i < adders.length; i++)		{			System.out.println("adder #" + i + " is " + (adders[i].isAlive() ? "alive" : "terminated"));			if (!adders[i].isAlive())			{				num_dead++;			}		}		assertEquals(num_dead, 10);		queue.close(false); // will cause all threads still blocking on peek() to return	}