java 同步、异步、阻塞和非阻塞分析

2025-05-29 0 48

java 同步异步阻塞非阻塞分析

概要:

正常情况下,我们的程序以同步阻塞的方式在运行。但是我们的程序总会出现一些耗时操作,比如复杂的计算(找出1到10亿之间的素数)和程序本身无法控制的操作(IO操作、网络请求)。包含这些耗时操作的方法我们可以把它称为阻塞方法,包含这些耗时操作的任务我们可以把它称为阻塞任务。阻塞与非阻塞是以是否耗时来定义的。

如果程序中存在大量阻塞操作,就会影响程序性能。但是阻塞的存在是客观事实,我们的程序是无法改变它的,一个网络请求需要3秒才能响应,我们不可能让它1毫秒就能响应,因为接受请求的服务器可能完全不由我们控制。但是我们可以改变处理阻塞的方式——以异步的方式处理阻塞任务。实现异步的主要技术就是多线程。图示:

java 同步、异步、阻塞和非阻塞分析

同步异步是个时序概念。同步就是同时只执行一个任务,而异步则是同时执行多个任务。

代码示例

模拟网络请求:

?

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(){

// 模拟网络请求

try {

Thread.sleep(1000 * 5);

} catch (InterruptedException e) {

e.printStackTrace();

Thread.currentThread().interrupt();

}

// 回调

this.callable.call("Hello world!");

}

public interface Callable{

void call(String result);

}

}

同步方式处理阻塞任务:

?

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;

/**

* 以同步的方式处理阻塞任务

* @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!");

}

}

结果:

?

1

2

3
Thread:main

Message from remote server:Hello world!

Thread main is over!

异步的方式处理阻塞任务:

?

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;

/**

* 以异步的方式处理阻塞任务

* @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!");

}

}

结果:

?

1

2

3
Thread main is over!

Thread:Thread-0

Message from remote server:Hello world!

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

原文链接:http://blog.csdn.net/zhangzeyuaaa/article/details/50275979

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 java 同步、异步、阻塞和非阻塞分析 https://www.kuaiidc.com/119158.html

相关文章

发表评论
暂无评论