Java Reference
In-Depth Information
{
try
{
lock.lock();
try
{
while (!bq.offer(ch))
{
lock.unlock();
Thread.sleep(50);
lock.lock();
}
System.out.println(ch+"
produced by producer.");
}
catch
(InterruptedException
ie)
{
assert false;
}
}
finally
{
lock.unlock();
}
}
}
};
executor.execute(producer);
Runnable consumer;
consumer = new Runnable()
{
public void run()
{
char ch = '\0';
do
