FutureTask使用完整示例

简介: MainActivity如下:package cc.cv;import java.util.concurrent.FutureTask;import android.
MainActivity如下:
package cc.cv;

import java.util.concurrent.FutureTask;
import android.os.Bundle;
import android.app.Activity;
/**
 * Demo描述:
 * FutureTask使用完整示例
 * 
 * FutureTask是一个Runnable的子类,在建立Thread对象时可将其作为参数传入
 * 
 * 详细步骤:
 * 1 建立实现了Callable接口的子类CallableImpl,并覆写其中的call()方法
 * 2 新建FutureTask对象以CallableImpl为参数
 * 3 新建子线程以FutureTask为参数,且启动线程
 * 
 * 在子线程运行时会调用CallableImpl中的()方法.
 * 但可在主线程中利用futureTask.isDone()判断子线程是否已经完成其工作
 * 也可在主线程中利用futureTask.get()来获取子线程的运行结果,更加准确地说是获取了call()方法的结果.
 * 所以可将FutureTask看成是对线程Thread的优化和改进
 * 
 * 参考资料:
 * 1 http://uule.iteye.com/blog/1539084
 * 2 http://lf6627926.iteye.com/blog/1538313
 * 3 http://blog.csdn.net/kaiwii/article/details/6773971
 * 
 */
public class MainActivity extends Activity {

	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.main);
		testFatureTask();
	}

	private void testFatureTask(){
		try {
			CallableImpl callableImpl=new CallableImpl();
			FutureTask<Integer> futureTask=new FutureTask<Integer>(callableImpl);
			
			//在主线程中开启子线程
			new Thread(futureTask).start();
			System.out.println("子线程开始运行");
			
			//在主线程中判断子线程是否已经完成工作
			while(!futureTask.isDone()){
				System.out.println("在主线程中判断子线程的工作是否已经完成");
				System.out.println("子线程的工作还在进行中...........");
			}
			
			//在主线程中获取子线程的运行结果
			System.out.println("子线程运行结束,结果:"+futureTask.get());
			
		} catch (Exception e) {
			
		}
	}

}



CallableImpl如下:

package cc.cv;

import java.util.concurrent.Callable;

public class CallableImpl implements Callable<Integer> {
	private final int COUNTER = 9527;

	public CallableImpl() {

	}

	@Override
	public Integer call() throws Exception {
		try {
			System.out.println("...模拟子线程中的耗时工作...线程名称:"+ Thread.currentThread().getName());
			Thread.sleep(1000 * 5);
			System.out.println("...模拟子线程中的耗时工作...线程名称:"+ Thread.currentThread().getName());
			Thread.sleep(1000 * 7);
			System.out.println("...模拟子线程中的耗时工作...线程名称:"+ Thread.currentThread().getName());
		} catch (Exception e) {
			
		}
		return COUNTER;
	}

}


main.xml如下:

<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:paddingBottom="@dimen/activity_vertical_margin"
    android:paddingLeft="@dimen/activity_horizontal_margin"
    android:paddingRight="@dimen/activity_horizontal_margin"
    android:paddingTop="@dimen/activity_vertical_margin"
    tools:context=".MainActivity" >

    <TextView
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="@string/hello_world" />

</RelativeLayout>

相关文章
|
Java
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
71 0
ThreadPoolExecutor的中的submit和FutureTask || 通过Executors 创建线程池的一些实例(Callable和Runnable的在其中的体现)
ThreadPoolExecutor的中的submit和FutureTask || 通过Executors 创建线程池的一些实例(Callable和Runnable的在其中的体现)
199 0
|
Java
Callable、Future、FutureTask在多线程中的应用场景
Callable、Future、FutureTask在多线程中的应用场景
277 0
|
Java 调度 容器
Java中的Runnable、Callable、Future、FutureTask的区别与示例
Java中的Runnable、Callable、Future、FutureTask的区别与示例
209 0
|
Java
从源码看异步任务计算FutureTask
大家是否熟悉FutureTask呢?或者说你有没有异步计算的需求呢?FutureTask就能够很好的帮助你实现异步计算,并且可以实现同步获取异步任务的计算结果。下面我们就一起从源码分析一下FutureTask。
90 0
|
存储 Java
JUC系列(六) | Callable和Future接口详解&使用、FutureTask应用 获取异步线程返回值
JUC系列(六) | Callable和Future接口详解&使用、FutureTask应用 获取异步线程返回值
404 0
JUC系列(六) | Callable和Future接口详解&使用、FutureTask应用 获取异步线程返回值
|
Java API 网络架构
20个使用 Java CompletableFuture的示例(下)
20个使用 Java CompletableFuture的示例(下)
270 1
|
Java API
20个使用 Java CompletableFuture的示例(上)
20个使用 Java CompletableFuture的示例(上)
492 0
20个使用 Java CompletableFuture的示例(上)
两个例子解释Callable 和 Future接口
两个例子解释Callable 和 Future接口
搞懂Runnable Callable Future FutureTask 及应用
搞懂Runnable Callable Future FutureTask 及应用