java使用回调和线程处理一个耗时响应全过程

现在程序中有许多涉及长耗时响应过程的处理,比如访问WebService,远程调用,复杂处理等,如果我们使用直接顺序执行的方式进行处理有可能导致界面停顿,响应停止,无谓等待等缺陷,这是不应该的。

一个耗时响应过程应该采用回调和线程来处理,具体就是把原来的顺序执行修改为异步方式,并让被调用者调用调用者以获得执行结果。在附件的例子中,Viewer就是调用者,它代表界面,而LongTimeResponse是被调用者,它内部用线程启动一个耗时过程,执行完毕再通知调用者。

Viewer类代码如下:

public class Viewer{
   private int count;
  
   public Viewer(int count){
     this.count=count;
   }
  
   public void printNewCount(int newCount){
     System.out.println("New Count="+newCount);
   }
   public int getCount() {
     return count;
   }
   public void setCount(int count) {
     this.count = count;
   }
}


LongTimeResponse类代码如下,可以看出,它之所以能回调调用者,是因为其内部有调用者的引用viewer,在其构造函数中viewer被赋上了值:

package com.sitinspring;
public class LongTimeResponse implements Runnable{
   private Viewer viewer;
   private int count;
  
   public LongTimeResponse(Viewer viewer){
     this.viewer=viewer;
     this.count=viewer.getCount();
    
     caculateNewCount();
   }
  
   private void caculateNewCount(){
     Thread thread=new Thread(this);
     thread.start();
   }
  
   public void run(){
     try{
       Thread.sleep(10000);  
     }
     catch(Exception ex){
       ex.printStackTrace();
     }
    
     viewer.printNewCount(count*count*count);
   }
}


调用过程如下:

Viewer viewer=new Viewer(10);

LongTimeResponse longTimeResponse=new LongTimeResponse(viewer);

viewer.printNewCount(123);

执行起来可以看出,程序先输出了

New Count=123

过了十秒,才输出:

New Count=1000

这说明,程序是异步执行的,耗时过程没有影响到主干程序的运行,而耗时过程完成后,才把返回结果通知了调用者,主干程序没有受到耗时过程的影响,因此也就不会导致界面停顿,响应停止,无谓等待等缺陷。

以上就是使用回调和线程处理一个耗时响应的整个过程。

时间: 2024-09-14 15:15:35

java使用回调和线程处理一个耗时响应全过程的相关文章

c# 怎么延时等待 一个耗时操作的返回

问题描述 点击按钮时调用一个耗时函数,会导致界面假死因为这个耗时函数是需要返回参数的,如果调用新进程去执行,怎么接收它的返回.这种情况要怎么处理,谢谢 解决方案 解决方案二:把接收到的返回值先放到一个全局变量里,然后在给线程结束注册个回调事件,线程结束了,主线程就调用这个事件,然后到全局变量里拿数据解决方案三:耗时函数应该另开个线程执行,可以写个委托来处理返回结果,用信号量或者静态变量也行.解决方案四:引用2楼china_ggd的回复: 耗时函数应该另开个线程执行,可以写个委托来处理返回结果,用

java web应用中新起一个线程 在线程中怎么获取系统登录的数据

问题描述 java web应用中新起一个线程 在线程中怎么获取系统登录的数据 java web应用中新起一个线程 在线程中怎么获取系统登录的数据,系统登录用的是Spring Secrity 解决方案 可以使用缓存,自己写一个缓存类.或者使用Redis.

多线程-JAVA中如何在一个线程里面停掉另一个线程

问题描述 JAVA中如何在一个线程里面停掉另一个线程 JAVA中如何在一个线程里面停掉另一个线程,是在一个线程里面哦 PS:新人第一次问问题,希望大神求教 解决方案 定义一个共享变量在run方法里面 while(start){ } 解决方案二: 所以说,这个问题的答案是:不可以! 虽然的确有那么个方法可以摧毁别人的线程,但很早很早就已经过期了,如果没记错的话我之前也这么玩,而结果是这个过期的方法根本没有作用-- 虽然说办法不是没有,那就是通过改变变量值,它知道自己该死了,就退出循环,走向结束.

java 中如何实现多个线程共享一个类

问题描述 java 中如何实现多个线程共享一个类 预想: 一个类 ClassA 中的一个类变量 public static int data = 100; 我起一个main方法 调用 ClassA.data = 200; 再起一个main方法 读取ClassA.data 获取的值就是200? 任意线程修改单例的ClassA 其他线程读取都是最新的 如何做到? 解决方案 java如何实现多个线程并发运行 解决方案二: 启动2个main,不是线程,是进程. 解决方案三: 用final修饰 publi

请教一个java线程的一个小问题,求程序执行流程,打印结果为1000 b=1000

问题描述 public class Test implements Runnable{int b = 100;public synchronized void m1() throws Exception{b =1000;Thread.sleep(5000);System.out.println("b:"+b);}public synchronized void m2() throws Exception{Thread.sleep(2500);b = 2000;}public void

vc++-信号量和线程同步的问题:线程函数比较耗时

问题描述 信号量和线程同步的问题:线程函数比较耗时 void trigger() { UINT uWait=::WaitForSingleObject(IEvent,INFINITE); if ( uWait == WAIT_OBJECT_0 ) { processA(); } } processA(); 比较耗时,如果它还没有跑完,下一个触发又来了,就马上又开始执行一个processA(); 吗,还是等待上次的执行完成然后再执行? 解决方案 PC机上会出现乱序或是假死,也就是说有可能后发的先做

Java基础-创建Java程序中的线程池

程序|创建 线程是Java的一大特性,它可以是给定的指令序列.给定的方法中定义的变量或者一些共享数据(类一级的变量).在Java中每个线程有自己的堆栈和程序计数器(PC),其中堆栈是用来跟踪线程的上下文(上下文是当线程执行到某处时,当前的局部变量的值),而程序计数器则用来跟踪当前线程正在执行的指令. 在通常情况下,一个线程不能访问另外一个线程的堆栈变量,而且这个线程必须处于如下状态之一: 1.排队状态(Ready),在用户创建了一个线程以后,这个线程不会立即运行.当线程中的方法start()被调

Java 6中的线程优化真的有效么?

介绍 - Java 6中的线程优化 Sun.IBM.BEA和其他公司在各自实现的Java 6虚拟机上都花费了大量的精力 优化锁的管理和同步.诸如偏向锁(biased locking).锁粗化(lock coarsening).由逸出(escape)分析产生的锁省略.自适应自旋锁(adaptive spinning)这些特性,都是通过在应用程序线程之间更高效地共享数据,从而提 高并发效率.尽管这些特性都是成熟且有趣的,但是问题在于:它们的承诺真的 能实现么?在这篇由两部分组成的文章里,我将逐一探究

Java开发中的线程安全选择与Swing

Swing API的设计目标是强大.灵活和易用.特别地,我们希望能让程序员们方便地建立新的Swing组件,不论是从头开始还是通过扩展我们所提供的一些组件. 出于这个目的,我们不要求Swing组件支持多线程访问.相反,我们向组件发送请求并在单一线程中执行请求. 本文讨论线程和Swing组件.目的不仅是为了帮助你以线程安全的方式使用Swing API,而且解释了我们为什么会选择现在这样的线程方案. 本文包括以下内容: ◆单线程规则:Swing线程在同一时刻仅能被一个线程所访问.一般来说,这个线程是事