我正在尝试使用类在并发 Java 中开发活动对象模式。java.util.concurrent
我用 aClient
和 a来描述它Server
。一个样本Server
如下:
class Server implements Runnable {
public final LinkedBlockingQueue que = new LinkedBlockingQueue();
private final ExecutorService es = Executors.newCachedThreadPool();
private Message currentMessage;
private boolean state = false;
public init() {
es.submit(this);
}
public void requestForServer() {
if (state) {
this.currentMessage.await();
}
state = true;
}
public void run() {
for(;;) {
Message m = que.take();
this.currentMessage = m;
this.es.submit(m);
}
}
}
和一个样本Client
:
class Client {
private Server server;
public Client(Server s) {
this.server = s;
}
public void doSomething() {
Message m = new Message(new Callable() {
public Object call() {
server.requestForServer();
}
});
this.server.que.add(m);
}
}
一个示例Message
封装是:
class Message<V> extends FutureTask<V> {
private Lock lock = new ReentrantLock();
private Condition condition = new Condition();
public Message(Callable<V> callable) {
super(callable);
}
public void run() {
try {
lock.lock();
super.run();
lock.unlock();
} catch(Exception e) {}
}
public void await() {
try {
condition.await();
} catch(Exception e) {}
}
public void signal() {
try {
condition.signalAll();
} catch(Exception e) {}
}
}
和一个示例运行代码:
Server s = new Server();
Client c = new Client (s);
s.init();
c.doSomething();
我删除了一些实现细节来传达我的信息。
现在,问题是在什么时候,Server
传入state
的true
消息应该等待并且await
在当前消息上调用。但是,我明白IllegalMonitorStateException
这意味着当前消息不拥有当前线程来等待它。但是,我认为这很奇怪,因为当前消息在Server
其线程池中被调用,因此当前消息也可以访问当前执行线程。
如果您有任何想法或建议,或者使用java.util.concurrent
. 提前致谢。
更新:我在这篇博
文中讨论了我可以部署的解决方案。我希望它可以帮助。