线程的启动与中止

2019-04-11  本文已影响0人  stevefat

线程的三种启动方式

  1. X extends Thread ;然后X.run
    2.X implements Runnable; 然后有Thread 来运行
    3.X implements Callable; 然后有Thread 来运行

第一种继承子Thread 类

public class ThreadExtends extends Thread{
    @Override
    public void run() {
        super.run();
        System.out.println("测试数据");

    }
}

启动方式:

 ThreadExtends threadExtends = new ThreadExtends();
 threadExtends.start();

第二种方式

实现Runnable 接口

public class ThreadRunnable implements Runnable {
    @Override
    public void run() {
        String name = Thread.currentThread().getName();
        System.out.println("测试Runnable currentThread"+name);
    }
}

启动方式:

new Thread(new ThreadRunnable()).start();

第三种 实现Callable<V> 接口,这种方式带有返回值的

import java.util.concurrent.Callable;

public class ThreadCall implements Callable<String> {
    @Override
    public String call() throws Exception {
        
        System.out.println("callable =======");
        
        return "测试";
    }
}

启动方式:

        ThreadCall call  = new ThreadCall();

        FutureTask<String> futureTask = new FutureTask<>(call);

        new Thread(futureTask).start();

        String s = futureTask.get();

        System.out.println(s);

输出:


实现Callable 接口的结果展示

以上三种方式,第 1,2 中方式运行完成以后无法获取运行的结果, 从JDK1.5 开始就提供了CallableFuture ,通过他们可以获取线程运行完成后的结果.
Callabel只是声明了一个接口,有个call() 的方法,只是一个泛型接口,call()函数返回的类型就是传进来的类型.

  //只是一个接口
@FunctionalInterface
public interface Callable<V> {
    /**
     * Computes a result, or throws an exception if unable to do so.
     *
     * @return computed result
     * @throws Exception if unable to compute a result
     */
    V call() throws Exception;
}

Future 就是对具体的RunnableCallable 任务的执行结果进行取消、查询和是否完成、获取结果。
必要时用get() 方法获取执行结果,但是该方法会阻塞到任务结束返回结果。
因为Future 是一个接口,无法直接用来从创建对象的,因此就有了FutureTask

public class FutureTask<V> implements RunnableFuture<V>
package java.util.concurrent;

/**
 * A {@link Future} that is {@link Runnable}. Successful execution of
 * the {@code run} method causes completion of the {@code Future}
 * and allows access to its results.
 * @see FutureTask
 * @see Executor
 * @since 1.6
 * @author Doug Lea
 * @param <V> The result type returned by this Future's {@code get} method
 */
public interface RunnableFuture<V> extends Runnable, Future<V> {
    /**
     * Sets this Future to the result of its computation
     * unless it has been cancelled.
     */
    void run();
}

FutureTask 实现了RunnableFuture 接口,RunnableFuture接口集成了Runnable接口和Future 接口,所以它皆可以作为Runnable被线程执行,有可以作为Future得到Callable得到返回值。事实上FutureTaskFuture 的唯一实现类。要new 一个FutureTask 有两个方法:

FutureTask 可参考上文的实现方式。

中止

上一篇下一篇

猜你喜欢

热点阅读