国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學(xué)院 > 開發(fā)設(shè)計(jì) > 正文

完整性和不丟失的方式處理消息 BlockingQueue類

2019-11-08 00:25:34
字體:
供稿:網(wǎng)友
用到隊(duì)列機(jī)制。
BlockingQueue類就是先進(jìn)先出的隊(duì)列,還有很多其他隊(duì)列類。
用法:
1,聲明創(chuàng)建BlockingQueue類
2,創(chuàng)建一個(gè)子線程的類,業(yè)務(wù)處理放在子線程中,并實(shí)例化,將BlockingQueue的類對象傳進(jìn)去
3,有消息的時(shí)候就將消息加進(jìn)BlockingQueue的類對象中:
Message msg=new Message();
queue.add(msg);
BlockingQueue<Message> queue = new ArrayBlockingQueue<Message>(2048);
Consumer c = new Consumer(queue);new Thread(c).start();
class Consumer implements Runnable{    PRivate final BlockingQueue<Message> queue;    public Consumer(BlockingQueue<Message> q){        this.queue = q;    }    public void run() {        while(true){               Message msg= queue.take();
          }    }}
發(fā)表評論 共有條評論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 咸宁市| 自治县| 娱乐| 浦北县| 三原县| 陈巴尔虎旗| 昌吉市| 南丹县| 思茅市| 阳高县| 邻水| 阳西县| 郁南县| 辉县市| 石林| 宾川县| 遂溪县| 城固县| 手游| 柳州市| 冀州市| 潜江市| 铁力市| 彭州市| 乌苏市| 尚义县| 通化县| 宝清县| 浦东新区| 遂平县| 富平县| 桃源县| 福州市| 会昌县| 潢川县| 乳山市| 广安市| 揭东县| 桑植县| 醴陵市| 河池市|