剛才想到解法, 不知是否完美, 吝請各位高手指教, 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