关于 messagelist,怎么死掉了???
我目前正在做一个通信的程序,要从数据库内取出信息,发给服务端
由于数据量较大,大概是这样实现的:
大概结构图如下
服务端 <- sendThread <- messageList<- getThread <- database;
messageList 的实现跟《JAVA实用系统开发指南》上实现是一样的
采用两个线程
getThread:获取数据线程,从数据库中取得数据(简单讲就是轮询DB里的一个表),push 到 messagelist
sendThread: 从 messageList remove 信息,发送出去,sendThread可以有多个实例,也就是建立多条链发送。
但当我的程序写好时,运行两个线程,DB里有数据时,正常,当数据读完时,就停了,当再次往DB里写入数据也没用,感觉死掉了,什么原因呢?
我SOCKET 用得不是 NIO。我不知道这样讲,大家会不会听得懂!!!
先谢了!!