amp@java

            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
            99 隨筆 :: 0 文章 :: 228 評論 :: 0 Trackbacks
          改了一下實現,采用“生產者-消費者”模式。每個串口一個線程,讀取BlockingQueue里的待發信息,作為消費者,發送完畢后把發送結果寫到另外一個BlockingQueue里;查詢線程定時查詢數據庫,獲得待發信息并加入到BlockingQueue里;結果更新線程讀取BlockingQueue里的短信發送結果,更新到數據庫里,并把結果發送到客戶端。
          這樣會帶來一個問題,發送線程發送短信需要一定的時間,可能某條待發信息已經在隊列里了,但查詢線程并不知道,繼續把該信息入列,所以發送線程在發送某條短信前要檢查數據庫,看是否已經發送過,如果發送過,則不再發送。
          posted on 2006-10-25 17:34 amp@java 閱讀(789) 評論(0)  編輯  收藏 所屬分類: Java common
          主站蜘蛛池模板: 天柱县| 红安县| 高邮市| 灵宝市| 鞍山市| 阿拉善盟| 东乡| 铜陵市| 九寨沟县| 贞丰县| 美姑县| 太谷县| 永修县| 横峰县| 乐业县| 南雄市| 德阳市| 内江市| 绥德县| 鹤壁市| 沂源县| 南通市| 保定市| 高碑店市| 永修县| 盐池县| 富顺县| 崇礼县| 即墨市| 镇康县| 东港市| 龙山县| 金沙县| 阿拉善右旗| 绥棱县| 洛阳市| 湖北省| 靖西县| 封开县| 仁寿县| 旺苍县|