用到隊(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();} }}
新聞熱點(diǎn)
疑難解答