专栏首页Coding DiaryJava中实现线程的方式

Java中实现线程的方式

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中的一个,关于线程池的详细内容将会在下一篇继续,欢迎大家关注。

本文分享自微信公众号 - Coding Diary(gh_7e1f05090980)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-07-11

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • java之初识hibernate

    1. 使用jdbc进行数据库操作:获取数据库连接,编写sql语句,执行sql操作,关闭连接。

    Vincent-yuan
  • Spock 测试框架的介绍和使用详解

    Spock 框架是一个基于groovy语法的测试框架,由于使用groovy,所以使用起来比 junit 更加灵活,测试用例的写法更加简单易懂,一目了然。

    yawn
  • es6 --- Generator 函数

    在 ES6 出现之前,基本都是各式各样类似Promise的解决方案来处理异步操作的代码逻辑,但是 ES6 的Generator却给异步操作又提供了新的思路,马上...

    小蔚
  • java之struts2之类型转换

    在使用servlet开发中,表单中提交的数据到servlet后都是字符串类型,需要程序员手动进行类型转换。

    Vincent-yuan
  • es6 -- Iterator 和 for...of 循环

    JavaScript 原有的表示“集合”的数据结构,主要是数组(Array)和对象(Object),ES6 又添加了Map和Set。这样就有了四种数据集合,用户...

    小蔚
  • loadrunner 脚本开发-web_custom_request函数详细介绍

    int web_custom_request(const char *RequestName, ,

    授客
  • java之struts2之ajax

    1.Ajax 技术在现有开发中使用非常多,大多是做管理类型系统。在servlet中可以使用ajax。在struts2中共还可以使用servlet的方式来实现aj...

    Vincent-yuan
  • Python 基于python实现单例模式

    简单说,单例模式(也叫单件模式)的作用就是保证在整个应用程序的生命周期中,任何一个时刻,单例类的实例都只存在一个(当然也可以不存在)

    授客
  • java之struts2之文件上传

    1.在大多数应用中,都有文件上传功能。有两种文件上传的方式,一种是自己去解析http协议,获取文件上传的内容。另一种是通过第三方插件来实现文件上传。第三方插件一...

    Vincent-yuan
  • 使用myeclipse修改项目映射路径

    实例url:http://localhost:8080/myFirstServlet/one

    Vincent-yuan

扫码关注云+社区

领取腾讯云代金券