概要：
正常情況下，我們的程序以同步非阻塞的方式在運(yùn)行。但是我們的程序總會(huì)出現(xiàn)一些耗時(shí)操作，比如復(fù)雜的計(jì)算（找出1到10億之間的素?cái)?shù)）和程序本身無法控制的操作（IO操作、網(wǎng)絡(luò)請(qǐng)求）。包含這些耗時(shí)操作的方法我們可以把它稱為阻塞方法，包含這些耗時(shí)操作的任務(wù)我們可以把它稱為阻塞任務(wù)。阻塞與非阻塞是以是否耗時(shí)來定義的。
如果程序中存在大量阻塞操作，就會(huì)影響程序性能。但是阻塞的存在是客觀事實(shí)，我們的程序是無法改變它的，一個(gè)網(wǎng)絡(luò)請(qǐng)求需要3秒才能響應(yīng)，我們不可能讓它1毫秒就能響應(yīng)，因?yàn)榻邮苷?qǐng)求的服務(wù)器可能完全不由我們控制。但是我們可以改變處理阻塞的方式——以異步的方式處理阻塞任務(wù)。實(shí)現(xiàn)異步的主要技術(shù)就是多線程。圖示：
同步和異步是個(gè)時(shí)序概念。同步就是同時(shí)只執(zhí)行一個(gè)任務(wù)，而異步則是同時(shí)執(zhí)行多個(gè)任務(wù)。
代碼示例
模擬網(wǎng)絡(luò)請(qǐng)求：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
package com.zzj.asyn; public class HttpRequest { private Callable callable; public HttpRequest(Callable callable) { this.callable = callable; } public void send(){ // 模擬網(wǎng)絡(luò)請(qǐng)求 try { Thread.sleep(1000 * 5); } catch (InterruptedException e) { e.printStackTrace(); Thread.currentThread().interrupt(); } // 回調(diào) this.callable.call("Hello world!"); } public interface Callable{ void call(String result); } } |
以同步方式處理阻塞任務(wù)：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
package com.zzj.asyn; import com.zzj.asyn.HttpRequest.Callable; /** * 以同步的方式處理阻塞任務(wù) * @author lenovo * */public class App { public static void main(String[] args) { new HttpRequest(new Callable() { @Override public void call(String result) { System.out.println("Thread：" + Thread.currentThread().getName()); System.out.println("Message from remote server：" + result); } }).send(); System.out.println("Thread " + Thread.currentThread().getName() + " is over!"); } } |
結(jié)果：
|
1
2
3
|
Thread：main Message from remote server：Hello world! Thread main is over! |
以異步的方式處理阻塞任務(wù)：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
package com.zzj.asyn; import com.zzj.asyn.HttpRequest.Callable; /** * 以異步的方式處理阻塞任務(wù) * @author lenovo * */public class App2 { public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { new HttpRequest(new Callable() { @Override public void call(String result) { System.out.println("Thread：" + Thread.currentThread().getName()); System.out.println("Message from remote server：" + result); } }).send(); } }).start(); System.out.println("Thread " + Thread.currentThread().getName() + " is over!"); } } |
結(jié)果：
|
1
2
3
|
Thread main is over! Thread：Thread-0Message from remote server：Hello world! |
感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！
原文鏈接：http://blog.csdn.net/zhangzeyuaaa/article/details/50275979
