`
xuyongping
  • 浏览: 124250 次
  • 性别: Icon_minigender_1
  • 来自: 部落格
社区版块
存档分类
最新评论

超时任务

 
阅读更多
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

/**
*
* @author Kaiwii Ho
* Callable类就是一个有返回值的任务
* 对于任务与Thread之间的关系,可以这样子理解:
* Callable类的实例就是一个锦囊妙计;而Thread就是执行这个锦囊妙计的过程
*
* FutureTask类(Future接口的一个实现)就是一个监视器:检测着被若干个异步线程操作的变量的一个类
*
* 代码演示了主线程如何通过使用Callable类和FutureTask类,实现:
* 主线程一边等待子线程的处理结果,一边完成自己的工作。
*
*考虑以下一个小黑工kaiwii的故事……
*/
public class TestFutureTask {
   


    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        //准备一份工作给一个打工仔employee叫Kaiwii
        Employee kaiwii=new Employee("kaiwii");
        //新建一个监工头inspector
        FutureTask<Double>inspector=new FutureTask<Double>(kaiwii);
        //让kaiwii这个打工仔工作
        System.out.println("老板发话,让kaiwii这个打工仔工作吧!");
        new Thread(inspector).start();
        System.out.println("老板开始数钱!");
        //老板一边数钱,一边命令监工inspector监视Kaiwii工作;一旦kaiwii完成工作就拿来让他检查
        while(!inspector.isDone()){
            System.out.println("老板数钱中……");
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
           
        }
        //老板交监工inspector将kaiwii的结果呈上来以便他验收kaiwii计算出来的结果
        try {
            System.out.println("老板发现kaiwii的结果是:"+inspector.get());
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (ExecutionException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

//子线程
class Employee implements Callable<Double>{
    String employee_name;
   
    private void setEmployee_name(String employee_name) {
        this.employee_name = employee_name;
    }
   
    public Employee(String employee_name) {
        setEmployee_name(employee_name);
    }
    @Override
    public Double call() throws Exception {
        // TODO Auto-generated method stub
        System.out.println("工人"+employee_name+"说:我开始工作了!!!!");
        for(int i=1;i<=10;i++){
            System.out.println("工人"+employee_name+" 第"+i+"次说:我在工作呢!!!!");
            Thread.sleep(1000);
        }
        System.out.println("工人"+employee_name+"说:我搞好了!!!!");
        return Math.random();
    }
}
分享到:
评论

相关推荐

    基于Java+netty内置时间轮工具处理大批量定时或超时任务工具源码.zip

    在这个项目中,我们关注的是如何利用Netty内置的时间轮(TimeWheel)工具来处理大批量的定时或超时任务。 时间轮是一种高效的数据结构,常用于实现定时器和延迟队列。它是由一系列的槽(Bucket)组成,每个槽代表一...

    C#函数超时执行事例

    // 如果是超时任务完成,取消函数任务并抛出异常 else { cancellationTokenSource.Cancel(); throw new TimeoutException($"函数执行超时,已取消。"); } } } ``` 在这个示例中,`ExecuteWithTimeout`方法...

    Tcpclient连接服务器连接超时设置

    它创建了一个新的`Socket`对象,然后同时启动连接任务和超时任务。当任一任务完成时,检查哪个任务先完成。如果连接任务先完成,那么创建一个新的`TcpClient`实例并返回;如果超时任务先完成,则抛出一个`...

    BlockingQueue队列自定义超时时间取消线程池任务

    在超时后,我们可以调用`cancel`方法尝试取消任务,但要注意的是,只有当任务尚未开始执行或者正在执行的任务可以被中断时,`cancel`方法才能成功。 以下是一个简单的示例: ```java ExecutorService executor = ...

    Java实现任务超时处理方法

    Java实现任务超时处理方法是指在Java中对超时任务的处理,主要有两种方式:基于异步任务结果的超时获取和使用延时任务来终止超时操作。 基于异步任务结果的超时获取是通过使用Future对象来实现的。在提交任务时,会...

    vCenter任务、事件清除

    "vCenter任务、事件清除"是指在vCenter Server中对积累的任务记录和事件通知进行清理的过程。这通常是为了优化系统性能,减少存储占用,以及保持管理界面的清晰整洁。 vCenter 6.x 版本引入了许多改进和增强,包括...

    异步编程超时取消并返回结果

    // 如果是超时任务完成,取消其他任务 if (completedTask == Task.Delay(timeoutMilliseconds)) { cts.Cancel(); throw new TimeoutException("请求超时"); } // 收集已完成的任务的结果 var results = new...

    边缘计算促进的超时控制网络边缘智能.pptx

    2. **及时检测的意义:** 及时检测和处理超时任务有助于防止系统资源的过度消耗,确保关键任务能够平稳可靠地执行。这对于保障边缘计算网络的整体稳定性和可靠性至关重要。 #### 二、超时控制算法在边缘网络中的...

    Java线程超时监控

    当我们提交一个任务到`ExecutorService`时,它会返回一个`Future`对象,我们可以利用这个对象来检查任务是否完成或者设置超时。 ```java ExecutorService executor = Executors.newSingleThreadExecutor(); Future...

    该框架是基于redis实现的分布式队列

    - 当检测到超时任务时,可以从队列中移除并重新放入,或者根据策略放入重试队列。 4. **故障恢复与幂等性**: - 在分布式环境中,任务可能会因网络问题或服务器故障而丢失,所以KMQueue可能包含一种方法来确保...

    多线程管理框架支持超时退出任务回调处理

    一直用线程池,但有些时候发现线程池无法控制结束某个超时等待的线程任务,所以就勉为其难的自己写了个线程管理~。作用:模仿线程池操作,管理多线程任务,超时,以及完成任务的回调。如果有bug自行处理,服务器挂机...

    shell-任务

    在`testovertime.sh`这个脚本中,我们可以推测其可能涉及到的工作流程是检查或处理超时任务。例如,它可能遍历日志文件,查找运行时间超过预定阈值的进程,然后进行相应的操作,如发送警告邮件或强制终止进程。 ...

    C#超时方法 正则超时

    首先,`OutTimeClass.cs`可能包含了一个自定义的超时类,它可能提供了设置超时时间、执行任务以及在超时时抛出异常等功能。这样的类通常会使用`System.Threading.Tasks.Task`或`System.Threading.Timer`来监控任务的...

    Android 异步任务 设置 超时使用handler更新通知功能

    为了设置超时,代码创建了一个新的线程,并在其中调用了`get()`方法,这个方法会阻塞直到任务完成或达到指定的超时时间。如果任务在10秒内未完成,`get()`方法会抛出`TimeoutException`。 当`TimeoutException`捕获...

    task:高效的线程池任务调度框架-开源

    不用担心task-running-overtime,因为task框架已经实现了对超时任务的监控,一旦任务超时,任务监控器会将其从线程池中移除,还能帮你自动结束超时任务。 3.任务调度框架性能优良,如果任务队列为空,框架会自动...

    TryRunWithTimeoutAsync测试

    这使得我们可以同时跟踪异步操作和超时任务,实现超时控制。 测试`TryRunWithTimeoutAsync`方法时,我们可能会创建一些模拟的异步操作,如模拟长时间运行的任务或者快速完成的任务,然后调用`...

    timeouter:创建和管理重复的超时任务

    创建和管理重复任务入门[sudo] npm install timeouter --save例子//Start a basic repeating logvar func = timeouter . add ( {func : function ( ) {console . log ( "Repeating event" )} ,timeout : 1000} )//...

    cpp-并行执行http请求支持超时设置

    通过`curl_multi_perform`可以并行执行这些请求,同时利用`curl_easy_setopt`设置超时参数,如`CURLOPT_TIMEOUT`来指定单个请求的超时时间。 压缩包中的`paw-master`可能是一个开源项目,它可能包含了实现上述功能...

    java通过线程控制程序执行超时(新)

    在Java编程中,控制程序执行超时是一项重要的任务,特别是在多线程环境下,我们可能需要确保某个任务不会无限制地运行下去,导致资源耗尽。本文将深入探讨如何使用Java的线程机制来实现程序执行的超时控制,同时也会...

    C#利用Task实现任务超时多任务一起执行的方法

    C#利用Task实现任务超时多任务一起执行的方法 本文主要介绍了C#利用Task实现任务超时,多任务一起执行的相关知识点。Task是C#中的一个异步编程模型,能够帮助开发者更方便地编写异步代码。下面是本文中所涉及的知识...

Global site tag (gtag.js) - Google Analytics