→ PsMonkey:請妥善引言 10/23 15:07
→ tnsshnews:抱歉, 如有觸犯, 請版主刪文, 請大家見諒!! 10/23 16:47
剛才想到解法, 不知是否完美, 吝請各位高手指教,
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