当前位置:首页 > Java技术 > java 多线程 获取线程返回结果

java 多线程 获取线程返回结果

2022年08月05日 21:10:15Java技术6

我们在使用java多线程编写相关业务代码时,往往有这样一种情况,某个线程依赖于其他线程执行结果。

也就是说,我们需要在一个线程中获取另一个线程的信息。可以分为两种情况,一种是轮询,一种是回调,因为轮询效率很低,所以本文主要介绍回调方法。

回调的主要思想是:线程run方法执行结束时,主动通知main线程,在main线程中做相应处理。通知main线程可以通过调用main方法中的static方法实现。

假定以下场景:

两个线程读取两个不同文件,最后拼接两个文件内容输出。

1、以下是线程代码:

 1 package com.ccg.test;
 2 
 3 import java.io.BufferedReader;
 4 import java.io.File;
 5 import java.io.FileInputStream;
 6 import java.io.InputStreamReader;
 7 
 8 public class CallbackThread implements Runnable{
 9 
10     private String fileName;
11     private TestMain callBack;
12     
13     public CallbackThread(TestMain callBack,String fileName) {
14         this.fileName = fileName;
15         this.callBack = callBack;
16     }
17 
18     @Override
19     public void run() {
20         try {
21             File file = new File(fileName);
22             InputStreamReader in = new InputStreamReader(new FileInputStream(file),"gbk");
23             BufferedReader br = new BufferedReader(in);
24             String str = br.readLine(); 
25             //通知线程调用者run方法执行结果
26             callBack.receiveFileStr(fileName,str);
27         } catch (Exception e) {
28             e.printStackTrace();
29         }
30     }
31 }

可以看到,在run方法结束时回调了线程调用者里面的方法。

2、线程调用者代码:

 1 package com.ccg.test;
 2 
 3 import org.junit.Test;
 4 
 5 public class TestMain {
 6 
 7     @Test
 8     public void test() throws InterruptedException{
 9         String f1 = "d:\\a.txt";
10         String f2 = "d:\\b.txt";
11         
12         TestMain t1 = new TestMain();
13         TestMain t2 = new TestMain();
14         
15         CallbackThread cb1 = new CallbackThread(t1, f1);
16         CallbackThread cb2 = new CallbackThread(t2, f2);
17         
18         new Thread(cb1).start();
19         new Thread(cb2).start();
20     }
21     
22     public void receiveFileStr(String fileName,String readStr){
23         StringBuffer sb = new StringBuffer();
24         sb.append(fileName + ":" + readStr);
25         System.out.println(sb.toString());
26     }
27 }

执行结果如下:

java 多线程 获取线程返回结果 _ JavaClub全栈架构师技术笔记

当然这只是最简单的应用,jdk1.5之后引入了Callable Executor Future的概念使得多线程编写代码更优雅,后面会介绍到。

来源链接:https://www.cnblogs.com/FlyHeLanMan/p/6956880.html

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/java/17950.html

分享给朋友:

“java 多线程 获取线程返回结果” 的相关文章

Java空指针异常解决java.lang.NullPointerException解决心得

Java空指针异常解决java.lang.NullPointerException解决心得

今天做课设的时候运行程序报出以下错误 java.lang.NullPointerException 首先要理解的是此错误并不会在 程序中报错,只会在运行的时候报错。 是由于某个参数(集合,数组等数据)可能出现一个null值而导致后面的程序不能运行时...

java基础知识讲解(一)数据类型和运算符

java基础知识讲解(一)数据类型和运算符

Java是一种强类型语言,每个变量都必须声明其数据类型。 Java的数据类型可分为两大类:基本数据类型(primitive data type)和引用数据类型(reference data type)。 Java中定义了3类8种基本数据类型 数值型- b...

全面了解 Java 原子变量类

📦 本文以及示例源码已归档在 javacore 一、原子变量类简介 为何需要原子变量类 保证线程安全是 Java 并发编程必须要解决的重要问题。Java 从原子性、可见性、有序性这三大特性入手,确保多线程的数据一致性。 确保线程安全最...

Java虚拟机1:什么是Java

Java虚拟机1:什么是Java

前言 让我们来看一下Java的广告词,来自http://www.java.com/zh_CN/about/: 97%的企业桌面运行Java 美国有89%的桌面(或计算机)运行Java 全球有900万Java开发人员 开发人员的头号选择...

Java 日志框架详解

Java 日志框架详解

1. JUL学习 JUL全称Java util Logging是java原生的日志框架,使用时不需要另外引用第三方类库,相对其他日志框 架使用方便,学习简单,能够在小型应用中灵活使用。 1.1 架构介绍 Loggers...

JDBC连接时所犯错误1.字符集设置不合适2.连接MySQL8.0社区版时时区不一致3..包名不能以Java.命名4.驱动被弃用

Microsoft JDBC Driver 的主页为:https://msdn.microsoft.com/en-us/data/aa937724.aspx 下载所需驱动 今天连接时报了四次错,记录下来 1.java.sql.SQLException:...

java计数循环及小技巧

要运行一个很大次数的循环应该选择一个小数,然后去判断 例如本例子是100可以选择10去判断 public static void main(String[] args) { // TODO Auto-generated metho...

java数数字及while和do while 的使用,以及程序的调试与验证

while的条件是在进入循环体之前判断的,执行完一轮循环之后,会再回到循环开始的地方再次判断条件,而不会在循环体中随时判断条件 1.while语句是当条件满足时不断的执行循环体内语句。 2.会提前判断是否满足条件,所以有可能一次也没有执行。 3.条件成立...

JAVA的JDK环境变量的配置JAVA

JAVA的JDK环境变量的配置JAVA

首先要在官网下载java 官网:http://www.oracle.com/technetwork/java/javase/downloads/ 到这个界面 选择我接受 记住该地址 最好的办法新建记事本,然后按ctrl+s保存 java环境变量的...

在JAVA 中将堆与栈分开的原因

栈是运行时的单位,而堆是存储的单位。 栈解决程序的运行问题,即程序如何执行,或者说如何处理数据;堆解决的是数据存储的问题,即数据怎么 放、放在哪儿。 注意:在Java中一个线程就会相应有一个线程栈与之对应 栈因为是运行单位,因此里面存储的信息都是跟...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。