日期:2014-05-19 浏览次数:21014 次
class MessageConsumer extends Thead {
private List<YourMessageType> list;
private boolean running = true;
public MessageConsumer(List<YourMessageType> list) {this.list = list;}
public void run() {
while (running) {
YourMessageType msg = null;
try {
synchronized(list) {
while (list.size() == 0) {
list.wait();
}
msg = list.remove(0);
list.notiryAll();
}
} catch (Exception e) {
e.printStackTrace();
}
if (msg == null) continue;
//System.out.println(msg); //print message
}
}
}
//调用sample
class ShareModule {
List<YourMessageType> list = new ArrayList<YourMessageType>();
...
}
public class Main {
public static void main(String[] args) {
ShareMudule sm; //so on
...
Thread t = new MessageConsumer(sm.list);
t.start();
...
}
}
------解决方案--------------------
为什么不用xian程,而用进程呢?
------解决方案--------------------
既然是 web 程序 用quartz 轮询不是挺好么。
------解决方案--------------------