Java中实现线程的方式

2019-07-11 21:56:51 阅读：142 来源： 互联网

标签：Java 方式 Thread 实现 Callable 线程 run public

Java中实现线程的方式

Java中实现多线程的方式的方式中最核心的就是 run()方法，不管何种方式其最终都是通过run()来运行。

Java刚发布时也就是JDK 1.0版本提供了两种实现方式，一个是继承Thread类，一个是实现Runnable接口。两种方式都是去重写run()方法，在run()方法中去实现具体的业务代码。

但这两种方式有一个共同的弊端，就是由于run()方法是没有返回值的，所以通过这两方式实现的多线程读无法获得执行的结果。

为了解决这个问题在JDK 1.5的时候引入一个Callable<V>接口，根据泛型V设定返回值的类型，实现他的call()方法，可以获得线程执行的返回结果。

虽然call()方法可以获得返回值，但它需要配合一个Future<V>才能拿到返回结果，而这个Future<V>又是继承了Runnable的一个接口。通过查阅源码就可以发现Future<V>的实现FutureTask<V>其在做具体业务代码执行的时候仍是在run()里面实现的。

FutureTask 源码片段：

public void run() {
        if (state != NEW ||
            !UNSAFE.compareAndSwapObject(this, runnerOffset,
                                         null, Thread.currentThread()))
            return;
        try {
            Callable<V> c = callable;
            if (c != null && state == NEW) {
                V result;
                boolean ran;
                try {
                    result = c.call();
                    ran = true;
                } catch (Throwable ex) {
                    result = null;
                    ran = false;
                    setException(ex);
                }
                if (ran)
                    set(result);
            }
        } finally {
            // runner must be non-null until state is settled to
            // prevent concurrent calls to run()
            runner = null;
            // state must be re-read after nulling runner to prevent
            // leaked interrupts
            int s = state;
            if (s >= INTERRUPTING)
                handlePossibleCancellationInterrupt(s);
        }
    }

Java多线程实现方式的代码示例:

通过继承Thread类实现

public class ThreadTest {

  public static void main(String[] args) throws Exception {
    Thread myThread = new MyThread();
    myThread.setName("MyThread-entends-Thread-test");
    myThread.start();

  }
}

class MyThread extends Thread {

  @Override
  public void run() {
    System.out.println("Thread Name:" + Thread.currentThread().getName());
  }
}

通过实现Runnable接口实现

public class ThreadTest {

  public static void main(String[] args) throws Exception {

    MyRunnableThread myRunnable = new MyRunnableThread();
    Thread myRunnableThread = new Thread(myRunnable);
    myRunnableThread.setName("MyThread-implements-Runnable-test");
    myRunnableThread.start();
  }
}

class MyRunnableThread implements Runnable {

  @Override
  public void run() {
    System.out.println("Thread Name:" + Thread.currentThread().getName());
  }
}

通过实现Callable接口实现

public class ThreadTest {

  public static void main(String[] args) throws Exception {

    Callable<String> myCallable = new MyCallableThread();
    FutureTask<String> futureTask = new FutureTask<>(myCallable);
    Thread myCallableThread = new Thread(futureTask);
    myCallableThread.setName("MyThread-implements-Callable-test");
    myCallableThread.start();
    System.out.println("Run by Thread:" + futureTask.get());

    //通过线程池执行
    ExecutorService executorService = Executors.newCachedThreadPool();
    executorService.submit(futureTask);
    executorService.shutdown();
    System.out.println("Run by ExecutorService:" + futureTask.get());
  }
}

class MyCallableThread implements Callable<String> {

  @Override
  public String call() throws Exception {
    return Thread.currentThread().getName();
  }
}

当然由于线程的创建和销毁需要消耗资源，Java中还通过了许多线程池相关的API,上述示例中ExecutorService就是线程池API中的一个，关于线程池的详细内容将会在下一篇继续，欢迎大家关注。

标签：Java,方式,Thread,实现,Callable,线程,run,public
来源： https://www.cnblogs.com/coding-diary/p/11172924.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Java中实现线程的方式