Java多线程的实现方法

Java虚拟机允许应用程序并发地运行多个线程。在Java语言中,多线程的实现一般有以下三种方法:

1)实现Runnable接口,并实现该接口的run()方法

class MyThread implements Runnable
{
  public void run(){
    System.out.println("Thread Body");
  } 
}

public class Test
{
  public static void main(String[] args)
 {
  MyThread thread = new MyThread();
  Thread t = new Thread();
  t.start();  //启动线程
  } 
}

2)继承Thread类,重写run方法

class MyThread extends Thread
{
 public void run()
 {
  System.out.println("Thread body");
  }
}

public class Test
{
 public static void main(String[] args)
 {
  MyThread thread = new MyThread();
  thread.start();
 }
}

3)实现Callable接口,重写call()方法

Callable对象实际是属于Executor框架中的功能类,Callable接口与Runnable接口类似,但是提供了比Runnable更强大的功能,主要表现在以下三点:

(1)Callable可以在任务结束后提供一个返回值,Runnable无法提供这个功能。

(2)Callable中的call()方法可以抛出异常,而Runnable的run()方法不能抛出异常。

(3)运行Callable可以拿到一个Future对象,Future对象表示异步计算的结果。它提供了检查计算是否完成的方法。由于线程属于异步计算模型,所以无法从其他线程中得到方法的返回值,在这种情况下,就可以使用Future来监视目标线程调用call()方法的情况,当调用Future的get()方法获取结果时,当前线程就会阻塞,直到call()方法结束返回结果。

import java.util.concurrent.*;
public class CallableAndFuture
{
 public static class CallableTest implements Callable<String>
 {
  public String call() throws Exception
  {
    return "Hello World";
  }
 }

public static void main(String[] args)
 {
  ExecutorService threadPool = Executors.newSingleThreadExecutor();
  Future<String> future = threadPool.submit(new CallableTest);
  try{
      System.out.println("waiting thread to finish");
      System.out.println(future.get());
  }
  catch(Exception e)
    {
      e.printStackTrace();
    }
 }
}

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/2d311b408b2eb7f0172168a5f9468da1.html