使用.wait和.notify对象池
我正在尝试在java中创建一个池对象的类。该类开始创建所需的最少数量的对象，当请求开始启动时，每个线程检查是否有可用对象，是否可以创建它因为尚未达到最大值，或者否则它必须等待得到一个。
想法是线程需要同步以获取/创建引擎，但它们可以并行处理（
ProcessWithEngine
.notify()
.wait()
.notify()
Queue _queue = new Queue();
int _poolMax = 4;
int _poolMin = 1;
int _poolCurrent =0;
public void Process(Object[] parameters) throws Exception
{
Engine engine = null;
synchronized(_queue)
{
if(_queue.isEmpty() && _poolCurrent >= _poolMax)
{
_queue.wait();
// HERE : sometimes _queue.isEmpty() is true at this point.
engine = (SpreadsheetEngine)_queue.dequeue();
}
else if (_queue.isEmpty() && _poolCurrent < _poolMax)
{
engine = CreateEngine();
_poolCurrent++;
}
else
{
engine = (Engine)_queue.dequeue();
}
}
ProcessWithEngine(engine, parameters);
// work done
synchronized(_queue)
{
_queue.enqueue(engine);
_queue.notify();
}
}
do
{
_queue.wait();
}
while(_queue.isEmpty());
没有找到相关结果
已邀请:
3 个回复
浆错
的调用都必须用循环括起来。拨打可以随意唤醒。 根据文档：“在一个参数版本中，中断和虚假唤醒是可能的，并且此方法应始终在循环中使用：”济畦刨
synchronized(stuff) { while (mustWait) wait(); // do things with stuff }并免费获得并发解决方案呢？断跑胺弄萎
- 在第一个线程称为并完成其块之后，但在第二个线程实际从其醒来之前。这是可能的，因为//不保证公平。 因此，应始终在循环内使用：while (_queue.isEmpty()) _queue.wait();