服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - java 同步、异步、阻塞和非阻塞分析

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

2020-08-05 11:36java教程网 Java教程

这篇文章主要介绍了java 同步、异步、阻塞和非阻塞分析的相关资料,需要的朋友可以参考下

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

延伸 · 阅读

精彩推荐