java 1.5以上的Future类可以执行超时处理。
jdk1.5自带的并发库中Future类中重要方法包括get()和cancel(),get()获取数据对象,如果数据没有加载,就会阻塞直到取到数据,而 cancel()是取消数据加载。另外一个get(timeout)操作,表示如果在timeout时间内没有取到就失败返回,而不再阻塞。
代码如下:
import java.util.concurrent.Callableimport java.util.concurrent.ExecutionException
import java.util.concurrent.ExecutorService
import java.util.concurrent.Executors
import java.util.concurrent.TimeUnit
import com.sun.corba.se.impl.orbutil.closure.Future
import com.sun.corba.se.impl.orbutil.threadpool.TimeoutException
public class ThreadTest {
public static void main(String[] args) throws InterruptedException,
ExecutionException {
final ExecutorService exec = Executors.newFixedThreadPool(1)
Callable<String> call = new Callable<String>() {
public String call() throws Exception {
//开始执行耗时操作
Thread.sleep(1000 * 5)
return "线程执行完成."
}
}
try {
Future<String> future = exec.submit(call)
String obj = future.get(1000 * 1, TimeUnit.MILLISECONDS) //任务处理超时时间设为 1 秒
System.out.println("任务成功返回:" + obj)
} catch (TimeoutException ex) {
System.out.println("处理超时啦....")
ex.printStackTrace()
} catch (Exception e) {
System.out.println("处理失败.")
e.printStackTrace()
}
// 关闭线程池
exec.shutdown()
}
}
java写文件流返回线程超时可以进行中断处理,包括中断线程并且返回超时的结果,有时候线程已经在执行了,是无法中断的,程序要返回超时的结果。Java是一门面向对象编程语言,1990年代初由詹姆斯·高斯林等人开发出Java语言的雏形,最初被命名为Oak,后随着互联网的发展,经过对Oak的改造,1995年5月Java正式发布。在A中设置B的初始状态为“未超时”,在B中超时的话就把状态置为“已超时”。然后A的判断初始阶段加一个对B状态的判断,如果B是“未超时”状态程序往下走,否则直接退出。PS:对提及多线程的那位仁兄表示匪夷所思,感觉跟多线程没有关系。