建站
咨詢
售后
建站咨詢
新聞中心
java 異步調(diào)用方法
1. 使用wait和notify方法
創(chuàng)新互聯(lián)公司堅持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都做網(wǎng)站、成都網(wǎng)站建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時代的宿豫網(wǎng)站設(shè)計、移動媒體設(shè)計的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！
這個方法其實是利用了鎖機(jī)制，直接貼代碼:
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ū)別，只是這里使用了條件鎖，兩者的鎖機(jī)制有所不同。
JAVA如何實現(xiàn)異步回調(diào)
FutureTaskString futureTask=new FutureTask(new CallableString() {
@Override
public String call() throws Exception {
// TODO Auto-generated method stub
return "回調(diào)完成";
}
});
try {
String str=futureTask.get();
if(str.equals("回調(diào)完成"))
System.out.println("異步任務(wù)完成!");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace(); }
如何用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)重影響程序性能,影響人機(jī)交互的瞬時反應(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)用方式
標(biāo)題名稱：java異步回調(diào)代碼,java中異步處理
URL地址：http://fisionsoft.com.cn/article/hossic.html
