刚才想到解法, 不知是否完美, 吝请各位高手指教, if(BlockingQueue.size() > 0){ bufferedwriter.write(BlockingQueue.take()); } ※ 引述《tnsshnews (tnsshnews)》之铭言： : 谢谢大大的分享, 小弟目前已经几乎要完成了, : 但遇到一个问题, 就是当BlockingQueue里面的东西都被取光, : 就会一直block在那边, thread2就不会结束, 一直hold在那边, : 也没有办法判断时间是不是超过五分钟, 要换档!! : ※ 引述《adrianshum (Alien)》之铭言： : : 这样做不是不可以，只是个人觉得这三个动作未至於独立到要分开 : : thread做，单 thread 就可以写得很有条理了。anyway, 後面继续 : : 建议避免这样做 polling. : : Java 本身就有现成好用的 producer-consumer queue (BlockingQueue) : : 改用 blocking queue，效果就是： : : Thread 1 一直写入新的 item : : Thread 2 一直从 queue 取得新的 item 写进档案。 : : 看起来就整洁许多。 : : 用 List 也差不多，只是你要小心 synchronize 的问题。 : : 直接用 ArrayList你会死很惨 : : 最基本的改法是加入适当的 synchronization control. : : 在写档时，改档案的 thread 就乖乖等；改档案时，就轮写档的 : : thread 在等。 : : 由於 Writer 或会丢弃，直接 synchronize writer 未必太适合， : : 可以弄一个 semaphore，或弄一个 dummy obj 作 mutex， 然後 : : 写档前及改档前就 lock : : 更进一步，为了让程式更好维护，不妨把这部份包得好看一点，比如： : : class DataItemOutput { : : private Writer writer; : : publc synchronized void writeItem(DataItem item) { : : writer.write(item.toString()); : : } : : public synchronized void rollFile() { : : writer.close(); : : // .... 开新 writer, 删旧档 etc : : } : : } : : 这样 thread 2 & 3 都变得很简单: : : Thread2: : : while (!end) { : : DataItem item = dataItemQueue.take(); : : dataItemOutput.writeItem(item); : : } : : Thread3: : : while (!end) { : : sleep(5 minutes); : : dataItemOutput.rollFile(); : : } : : 再更一步，Thread3 可以用 TimerTask, ScheduledExecutorService 之类 : : 然後再更进一步，你会发觉 roll file 的 thread 其实是多余的。 : : 只要你在 DataItemOutput.writeItem() 里，检查一下现在的 file : : 是什麽时候开，这五分钟就开新并纪绿新时间，Thread3 根本就没有 : : 存在必要了： : : class DataItemOutput { : : private Writer writer; : : private Date fileTime; : : publc void writeItem(DataItem item) { : : if (currentTime > fileTime + 5minutes) { : : rollFile(); : : } : : writer.write(item.toString()); : : } : : public void rollFile() { : : writer.close(); : : // .... 开新 writer, 删旧档 etc : : fileTime = currentTime; : : } : : } --

※ 发信站: 批踢踢实业坊(ptt.cc) ◆ From: 203.79.199.63