java的线程是由Thread来实现的,一般我们创建线程进行一个复杂的运算,然后在主线程中对运算结果进行处理,但是Thread的run函数并没有返回值,那么我们运算出结果后,怎么通知其它线程呢,本文讲述了几种返回信息的方法。
一。java线程的创建
要创建线程有两种办法,一是继承Thread类,二是实现Runnable,然后将其传递给一个Thread的构造函数,实例如下(假设我们要在一个线程中计算1到10000的和):
1。继承Thread:
public class AddThread extends Thread {
public void run() {
int result = 0;
for(int i = 1; i <= 10000; i++) {
result += i;
}
}
}
运行AddThread:
AddThread thread = new AddThread();
thread.start();
2。实现接口Runnable:
public class Add implements Runnable {
public void run() {
int result = 0;
for(int i = 1; i <= 10000; i++) {
result += i;
}
}
}
运行该线程: Thread thread = new Thread(new Add());
thread.start();
二、返回运算结果的方法
现在我们启动这个加法线程后,需要从这个线程中得到运算的结果,例如我们要在主线程中对运算结果进行显示。那么我们怎么实现呢?下面就讲述几种常见的方法,注意其中有一些是错误的方法
1。使用get方法(错误的)
我们可以在AddThread中加入一个getResult函数得到运算结果:
public class AddThread extends Thread {
private int result = 0;
public void run() {
for(int i = 0; i <= 10000; i++)
result += i;
}
public int getResult() {
return result;
}
}
/** 得到运算结果并显示在屏幕上
*/
public class Test {
public static void main(String[] args) {
AddThread thread = new AddThread();
thread.start();
System.out.println("result is " + thread.getResult());
}
}
得到的结果是: result is 0
因为这里主线程和addThread线程是同时运行,AddThread的运算还没有完成(甚至可能还没有开始),主线程就开始输出运算结果了,所以这种方式是错误的。
2。查询法(可行,但效率极低)
第二种方法是使用一个变量hasDone来表示运算是否完成,如果hasDone为false的时候表示运算尚未完成,否则表示运算已经完成。主线程不断查询这个变量,如果发现运算尚未完成,则进入循环等待,否则输出运算结果。
public class AddThread extends Thread {
private int result = 0;
private boolean hasDone = false;
public void run() {
for(int i = 0; i <= 10000; i++)
result += i;
hasDone = true;
}
public boolean hasDone() {
return hasDone;
}
public int getResult() {
return result;
}
}
public class Test {
public static void main(String[] args) {
AddThread thread = new AddThread();
thread.start();
file://如果运算没有完成,则循环等待
while (!thread.hasDone()) {
try {
Thread.sleep(100);
}
catch (InterruptedException ex) {
}
}
if (thread.hasDone())
System.out.println("result is " + thread.getResult());
}
}
结果显示: result is 50005000
主线程中循环查询运算的状态,如果运算没有完成,则主线程sleep100毫秒,然后继续查询,这种方式虽然可行,但由于主线程循环查询,消耗了大量的CPU时间,因此效率很低。
3。wait/notify方式(较好)
第三种方法使用wait/notify的形式,当运算没有结束的时候,主线程进入睡眠状态,这时它不占用CPU,因此效率较高。
public class AddThread
extends Thread {
file://在这个object上wait
private Object lock;
private int result = 0;
private boolean hasDone = false;
public AddThread(Object lock) {
this.lock = lock;
}
public void run() {
for (int i = 0; i <= 10000; i++)
result += i;
file://运算结束,通知等待的线程
synchronized(lock) {
hasDone = true;
lock.notifyAll();
}
}
public boolean hasDone() {
return hasDone;
}
public int getResult() {
return result;
}
}
file://主线程
public class Test {
public static void main(String[] args) {
Object lock = new Object();
AddThread thread = new AddThread(lock);
thread.start();
synchronized(lock) {
while (!thread.hasDone()) {
try {
file://当运算没有结束,主线程进入睡眠状态,当addThread执行notifyAll时,会唤醒主线程
lock.wait();
}
catch (InterruptedException ex) {
}
}
}
if (thread.hasDone())
System.out.println("result is " + thread.getResult());
}
}
4。使用callback(较好)
我觉得这是最好的一种方式,当运算完成后,AddThread自动调用结果处理类。将其扩展可以成为使多个listener对结果进行处理,这里用到了Observer模式,这种方法很简单,不需要考虑同步机制,具体实现如下:
file://对结果进行处理的接口
public interface ResultProcessor {
public void process(int result);
}
public class AddThread extends Thread {
private ResultProcessor processor;
public AddThread(ResultProcessor processor) {
this.processor = processor;
}
public void run() {
int result = 0;
for(int i = 0; i <= 10000; i++) {
result += i;
}
file://对结果进行处理
processor.process(result);
}
}
public class Test implements ResultProcessor {
public void process(int result) {
System.out.println("result is " + result);
}
public static void main(String[] args) {
Test test = new Test();
AddThread thread = new AddThread(test);
thread.start();
}
}
结果显示: result is 50005000
代码如上面,AddThread的构造函数传进一个结果处理类,当运算完成时,自动调用这个类的处理函数对结果进行处理。比较起来,我觉得这种方法最好。
分享到:
相关推荐
适合初学者使用,Java多线程技术实现矩阵乘积计算
4种常用Java线程锁的特点,性能比较、使用场景 线程(thread)是操作系统能够进行运算调度的最小单位。它被包含在进程之中,是进程中的实际运作单位。一条线程指的是进程中一个单一顺序的控制流,一个进程中可以并发...
西南科技大学java综合实验——多线程实现阶乘运算
Java多线程资源,对于学习很有帮助,如果有什么问题,欢迎大家一起探讨
一个用Java写的多线程相乘代码,及其测试。
JAVA_3 JAVA语言基础 位运算 JAVA_3 JAVA语言基础 JAVA_4 Java面向对象特性 JAVA_5 高级语言特征 JAVA_6 异常处理Exceptions JAVA_7 IO输入输出 JAVA_8 AWT图形界面编程 JFC AWT Swing JAVA_8 AWT图形界面编程 JFC ...
Java SE编程入门教程 java线程(共61页).pptx Java SE编程入门教程 java序列化(共14页).pptx Java SE编程入门教程 java异常(共57页).pptx Java SE编程入门教程 java正则(共8页).pptx Java SE编程入门教程 ...
Omega-AI:基于java打造的深度学习框架,帮助你快速搭建神经网络,实现训练或测试模型,支持多线程运算,框架目前支持BP神经网络、卷积神经网络、vgg16、resnet、yolo等模型的构建,目前引擎最新版本支持CUDA和CUDNN...
用java编写的一个矩阵乘法演示程序。主要表现多线程运算的过程。要求能用图形界面表现出比较形象的过程,两个矩阵数据随机生成,结果矩阵的每个元素各是一个线程的运行结果。
编写一多线程程序,实现如下功能: (1)一个线程进行阶乘和的运算(1!+2!+3!……+30!), 每次阶乘计算时间随机...(2)另一个线程每隔1秒时间读取上个线程的运算结果和计算 进程,并在图形界面中实时显示结果。
基于java打造的深度学习框架,帮助你快速搭建神经网络,实现模型推理与训练,引擎支持自动求导,多线程与GPU运算,GPU支持CUDA,CUDNN。
Omega-AI:基于java打造的深度学习框架,帮助你快速搭建神经网络,实现训练或测试模型,引擎支持自动求导,多线程与GPU运算。
1. 实验一 基本运算练习………………………3 2. 实验二 控制语句与数组练习………………7 3. 实验三 多态与嵌套…………………………12 4. 实验四 java的接口和GUI编程初步…… 19 5. 实验五 异常处理和多线程...
(2)另一个线程每隔1秒时间读取上个线程的运算结果和计算进程,并在图形界面中实时显示结果。 三、实验要求: 1、正确设计显示运行结果和计算进程的图形用户界面; 2、分别采用Thread类的子类和Runnable接口两种...
Omega-AI:基于java打造的深度学习框架,帮助你快速搭建神经网络,实现模型推理与训练,引擎支持自动求导,多线程与GPU运算,GPU支持CUDA,CUDNN。
1. 课程目的 1.1. 课程性质 JAVA 程序设计是计算机专业本科生的必修专业主干课程,授课对象为计算 ...编程要求:选择某一种运算后,根据输入的数据给出运算结果。 编程提示:在设计出的计算器界面上,。。。。。。
编写多线程程序,实现如下功能: (1)一个线程进行阶乘和的运算(1!+2!+3!+……+10!),每次阶乘计算时间随机间隔100-...(2)另一个线程每隔1秒时间读取上个线程的计算等式和运算结果,并在图形界面中实时显示。
division.java 演示整除结果 errorCompoundVariable.java 错误使用局部变量示例 factorial.java 求阶乘 Fibonacci.java 求Fiblnacci数列 GcdAndGcm.java 求最大公约数和最小公倍数 errorInit.java 演示变量...
Omega-AI:基于java打造的深度学习框架,帮助你快速搭建神经网络,实现训练或测试模型,支持多线程运算,框架目前支持BP神经网络、卷积神经网络、vgg16、resnet、yolo等模型的构建,目前引擎最新版本支持CUDA和CUDNN...