如何用JAVA實現(xiàn)異步信息處理

通常同步意味著一個任務(wù)的某個處理過程會對多個線程在用串行化處理，而異步則意味著某個處理過程可以允許多個線程同時處理。異步通常代表著更好的性能，因為它很大程度上依賴于緩沖，是典型的使用空間換時間的做法，例如在計算機當(dāng)中，高速緩存作為cpu和磁盤io之間的緩沖地帶協(xié)調(diào)cpu高速計算能力和磁盤的低速讀寫能力。

成都創(chuàng)新互聯(lián)公司服務(wù)項目包括巴林左旗網(wǎng)站建設(shè)、巴林左旗網(wǎng)站制作、巴林左旗網(wǎng)頁制作以及巴林左旗網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，巴林左旗網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到巴林左旗省份的部分城市，未來相信會繼續(xù)擴大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

（1）：重新啟動一個java程序就啟動了一個進(jìn)程

可以用操作系統(tǒng)命令行啟動 Runtime.getRuntime().exec("java -classpath . XXX");

（2）：可不可以在接收消息的模塊中的addtolist函數(shù)中添加一個專門的處理函數(shù)，函數(shù)執(zhí)行時先向list中添加消息，然后探測當(dāng)前有沒有處理線程，如果沒有，則啟動線程。

（3）：想省點工作，可以用BlockingQueue來代替list，這樣線程等待和喚醒不用寫代碼實現(xiàn)了，如果非要用list，那么就做好同步

list的小例子：

Java codeclass MessageConsumer extends Thead { ? ?private ListYourMessageType list; ? ?private boolean running = true; ? ?public MessageConsumer(ListYourMessageType list) {this.list = list;} ? ?public void run() { ? ? ? ?while (running) { ? ? ? ? ? ?YourMessageType msg = null; ? ? ? ? ? ? try { ? ? ? ? ? ? ? ?synchronized(list) { ? ? ? ? ? ? ? ? ? ?while (list.size() == 0) { ? ? ? ? ? ? ? ? ? ? ? ?list.wait(); ? ? ? ? ? ? ? ? ? ?} ? ? ? ? ? ? ? ? ? ?msg = list.remove(0); ? ? ? ? ? ? ? ? ? ?list.notiryAll(); ? ? ? ? ? ? ? ?} ? ? ? ? ? ?} catch (Exception e) { ? ? ? ? ? ? ? ?e.printStackTrace(); ? ? ? ? ? ?} ? ? ? ? ? ?if (msg == null) continue; ? ? ? ? ? ?//System.out.println(msg); //print message ? ? ? ?} ? ?}}//調(diào)用sampleclass ShareModule { ? ?ListYourMessageType list = new ArrayListYourMessageType(); ? ?...}public class Main { ? ?public static void main(String[] args) { ? ? ? ?ShareMudule sm; //so on ? ? ? ?... ? ? ? ?Thread t = new MessageConsumer(sm.list); ? ? ? ?t.start(); ? ? ? ?... ? ?}}

如何用Java回調(diào)和線程實現(xiàn)異步調(diào)用

軟件模塊之間的調(diào)用關(guān)系可以分為兩大類:即同步調(diào)用和異步調(diào)用。在同步調(diào)用中,一段代碼(主調(diào)方)調(diào)用另一段代碼(被調(diào)方),主調(diào)方必須等待這段代碼執(zhí)行完成返回結(jié)果后,才能繼續(xù)往下執(zhí)行,所以,同步調(diào)用是一種阻塞式調(diào)用,主調(diào)方代碼一直阻塞等待直到被調(diào)方返回為止。同步調(diào)用相對比較直觀,也是大部分編程語言直接支持的一種調(diào)用方式。但是,同步調(diào)用在處理比較耗時的情況下會嚴(yán)重影響程序性能,影響人機交互的瞬時反應(yīng)。例如,某個程序需要訪問數(shù)據(jù)庫獲取大量數(shù)據(jù),然后根據(jù)這些數(shù)據(jù)進(jìn)行一系列處理,將處理結(jié)果顯示在程序主窗口。由于數(shù)據(jù)庫訪問和大量數(shù)據(jù)的處理都是耗時的工作,在這個工作完成之前,處理結(jié)果遲遲不能顯示,用戶點擊鼠標(biāo)也不會立即得到響應(yīng),讓用戶感到整個程序顯得很沉重。面對這樣一些需要比較長時間才能完成的應(yīng)用場景,我們需要采用一種非阻塞式調(diào)用方式,即異步調(diào)用方式

java 異步發(fā)送短信，異步怎么實現(xiàn)

java 異步發(fā)送短信，異步實現(xiàn)：

1，使用spring框架的異步注解 @Async ，底層應(yīng)該是一個線程。

2，簡單粗暴的方式：開一個線程

new Thread(new Runnable() {

public void run() {

//發(fā)送短信

}

}).start();

當(dāng)然也可以高級一點，使用線程池。

3，更高端一點：使用消息隊列MQ

java 異步調(diào)用方法

1. 使用wait和notify方法

這個方法其實是利用了鎖機制，直接貼代碼:

public class Demo1 extends BaseDemo{ private final Object lock = new Object(); @Override public void callback(long response) { System.out.println("得到結(jié)果"); System.out.println(response); System.out.println("調(diào)用結(jié)束"); synchronized (lock) { lock.notifyAll(); } } public static void main(String[] args) { Demo1 demo1 = new Demo1(); demo1.call(); synchronized (demo1.lock){ try { demo1.lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println("主線程內(nèi)容"); } }

可以看到在發(fā)起調(diào)用后，主線程利用wait進(jìn)行阻塞，等待回調(diào)中調(diào)用notify或者notifyAll方法來進(jìn)行喚醒。注意，和大家認(rèn)知的一樣，這里wait和notify都是需要先獲得對象的鎖的。在主線程中最后我們打印了一個內(nèi)容，這也是用來驗證實驗結(jié)果的，如果沒有wait和notify，主線程內(nèi)容會緊隨調(diào)用內(nèi)容立刻打印;而像我們上面的代碼，主線程內(nèi)容會一直等待回調(diào)函數(shù)調(diào)用結(jié)束才會進(jìn)行打印。

沒有使用同步操作的情況下，打印結(jié)果:發(fā)起調(diào)用 調(diào)用返回 主線程內(nèi)容 得到結(jié)果 1 調(diào)用結(jié)束

而使用了同步操作后:

發(fā)起調(diào)用 調(diào)用返回 得到結(jié)果 9 調(diào)用結(jié)束 主線程內(nèi)容2. 使用條件鎖

和方法一的原理類似:

public class Demo2 extends BaseDemo { private final Lock lock = new ReentrantLock(); private final Condition con = lock.newCondition(); @Override public void callback(long response) { System.out.println("得到結(jié)果"); System.out.println(response); System.out.println("調(diào)用結(jié)束"); lock.lock(); try { con.signal(); }finally { lock.unlock(); } } public static void main(String[] args) { Demo2 demo2 = new Demo2(); demo2.call(); demo2.lock.lock(); try { demo2.con.await(); } catch (InterruptedException e) { e.printStackTrace(); }finally { demo2.lock.unlock(); } System.out.println("主線程內(nèi)容"); } }

基本上和方法一沒什么區(qū)別，只是這里使用了條件鎖，兩者的鎖機制有所不同。

文章題目：java異步代碼實現(xiàn) Java異步編程實戰(zhàn)
文章分享：http://vcdvsql.cn/article38/hehgpp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站制作、用戶體驗、服務(wù)器托管、電子商務(wù)、網(wǎng)站導(dǎo)航、網(wǎng)站策劃

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)