gpt4 book ai didi

浅谈java中异步多线程超时导致的服务异常

转载 作者:qq735679552 更新时间:2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章浅谈java中异步多线程超时导致的服务异常由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.

在项目中为了提高大并发量时的性能稳定性,经常会使用到线程池来做多线程异步操作,多线程有2种,一种是实现runnable接口,这种没有返回值,一种是实现Callable接口,这种有返回值.

当其中一个线程超时的时候,理论上应该不 影响其他线程的执行结果,但是在项目中出现的问题表明一个线程阻塞,其他线程返回的接口都为空。其实是个很简单的问题,但是由于第一次碰到,还是想了一些时间的。很简单,就是因为阻塞的那个线 。

程没有释放,并发量一大,线程池数量就满了,所以其他线程都处于等待状态.

附上一段自己写的调试代码,当想不出问题的时候,自己模拟的写写,说不定问题就出来了.

?
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
 
public class FutureTest
{
 
   public static void main(String[] args) throws InterruptedException,
     ExecutionException, TimeoutException
   {
 
     final ExecutorService exec = Executors.newFixedThreadPool( 1 );
    
 
     Callable<String> call = new Callable<String>() {
       public String call() throws InterruptedException
       {
         // 开始执行耗时操作
           Thread.sleep( 1000 * 2 );
         return "1线程执行完成." ;
       }
     };
 
     Callable<String> call2 = new Callable<String>() {
       public String call() throws Exception
       {
         // 开始执行耗时操作
         // Thread.sleep(1000 * 5);
         return "2线程执行完成." ;
       }
     };
    
     Callable<String> call3 = new Callable<String>() {
       public String call() throws Exception
       {
         // 开始执行耗时操作
         // Thread.sleep(1000 * 5);
         return "3线程执行完成." ;
       }
     };
 
     Future<String> future = exec.submit(call);
     Future<String> future3 = exec.submit(call3);
      Future<String> future2 = exec.submit(call2);
       String obj= "" ;
       String obj2 = "" ;
       String obj3 = "" ;
       try {
        obj = future.get( 500 , TimeUnit.MILLISECONDS); // 任务处理超时时间设为
       } // 1 秒
       catch (Exception e){
         System.out.println( "处理超时啦...." );
         e.printStackTrace();
       }
      
       try {
         obj3 = future3.get( 3000 , TimeUnit.MILLISECONDS); // 任务处理超时时间设为
         } // 1 秒
         catch (Exception e){
           System.out.println( "处理超时啦...." );
           e.printStackTrace();
         }
      
       try {
        obj2 = future2.get( 3000 , TimeUnit.MILLISECONDS);}
       catch (Exception e){
         System.out.println( "处理超时啦...." );
         e.printStackTrace();
       }
       System.out.println( "3任务成功返回:" + obj3);
       System.out.println( "2任务成功返回:" + obj2);
       System.out.println( "1任务成功返回:" + obj);
       exec.shutdown();
     }
}

以上就是小编为大家带来的浅谈java中异步多线程超时导致的服务异常全部内容了,希望大家多多支持我~ 。

最后此篇关于浅谈java中异步多线程超时导致的服务异常的文章就讲到这里了,如果你想了解更多关于浅谈java中异步多线程超时导致的服务异常的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com