Java中实现线程的方式

2023-01-09 07:32:46

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

码农公寓