amp@java

            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
            99 隨筆 :: 0 文章 :: 228 評論 :: 0 Trackbacks
          改了一下實現,采用“生產者-消費者”模式。每個串口一個線程,讀取BlockingQueue里的待發信息,作為消費者,發送完畢后把發送結果寫到另外一個BlockingQueue里;查詢線程定時查詢數據庫,獲得待發信息并加入到BlockingQueue里;結果更新線程讀取BlockingQueue里的短信發送結果,更新到數據庫里,并把結果發送到客戶端。
          這樣會帶來一個問題,發送線程發送短信需要一定的時間,可能某條待發信息已經在隊列里了,但查詢線程并不知道,繼續把該信息入列,所以發送線程在發送某條短信前要檢查數據庫,看是否已經發送過,如果發送過,則不再發送。
          posted on 2006-10-25 17:34 amp@java 閱讀(783) 評論(0)  編輯  收藏 所屬分類: Java common
          主站蜘蛛池模板: 南康市| 元朗区| 泉州市| 获嘉县| 河南省| 东兰县| 安康市| 宾川县| 巴青县| 宁远县| 蚌埠市| 长治县| 施秉县| 五常市| 灵山县| 通榆县| 井陉县| 新安县| 雷山县| 彩票| 马鞍山市| 普宁市| 仁怀市| 丹东市| 桂东县| 宾川县| 中卫市| 曲周县| 香港| 新巴尔虎左旗| 荆门市| 四会市| 庆阳市| 乌鲁木齐市| 洮南市| 阿拉尔市| 新竹市| 嘉禾县| 含山县| 朔州市| 渭南市|