JAVA多线程有哪几种实现方式呢？

转自：
  http://www.java265.com/JavaCourse/202204/2992.html
下文笔者讲述java中多线程的实现方式，如下所示:

1. JAVA中多线程主要有以下实现方式:
2.       1.继承Thread类
3.       2.实现Runnable接口
4.       3.使用ExecutorService、Callable、Future实现有返回结果的多线程
5. 注意事项:
6.       方式1和方式2线程运行完毕后，是没有返回值

复制代码

继承Thread类实现多线程

1.   注意事项:
2.      1.Thread本质上也是实现了Runnable接口的一个实例
3.            Thread它指一个线程实例
4.      2.启动Thread类，需使用start()方法
5.            start()方法是一个native方法
6.        它的功能:启动一个新线程,并执行run()方法
7.      3.使用Thread生成多线程，我们只需继承Thread类，重写run方法即可

复制代码

例:

1. public class MyThread extends Thread {
2. 　　public void run() {
3. 　　 System.out.println("MyThread.run()");
4. 　　}
5. }
7. //开启两个线程
8. MyThread myThread1 = new MyThread();
9. MyThread myThread2 = new MyThread();
10. myThread1.start();
11. myThread2.start();

复制代码

使用Runnable接口方式实现多线程

例:

1. //定义一个多线程
2. public class MyThread extends TestClass implements Runnable {
3. 　　public void run() {
4. 　　 System.out.println("MyThread.run()");
5. 　　}
6. }
8. //启动线程
9. MyThread myThread = new MyThread();
10. Thread thread = new Thread(myThread);
11. thread.start();

复制代码

使用ExecutorService、Callable、Future实现有返回结果的多线程

1. ExecutorService、Callable、Future 对象都属于Executor框架中的功能类

复制代码

例:多线程带返回值

1. import java.util.concurrent.*;
2. import java.util.Date;
3. import java.util.List;
4. import java.util.ArrayList;
6. /**
7. * 有返回值的线程
8. */
9. @SuppressWarnings("unchecked")
10. public class Test {
11. public static void main(String[] args) throws ExecutionException,
12.     InterruptedException {
13.    System.out.println("----程序开始运行----");
14.    Date date1 = new Date();
16.    int taskSize = 5;
17.    // 创建一个线程池
18.    ExecutorService pool = Executors.newFixedThreadPool(taskSize);
19.    // 创建多个有返回值的任务
20.    List<Future> list = new ArrayList<Future>();
21.    for (int i = 0; i < taskSize; i++) {
22.     Callable c = new MyCallable(i + " ");
23.     // 执行任务并获取Future对象
24.     Future f = pool.submit(c);
25.     // System.out.println(">>>" + f.get().toString());
26.     list.add(f);
27.    }
28.    // 关闭线程池
29.    pool.shutdown();
31.    // 获取所有并发任务的运行结果
32.    for (Future f : list) {
33.     // 从Future对象上获取任务的返回值，并输出到控制台
34.     System.out.println(">>>" + f.get().toString());
35.    }
37.    Date date2 = new Date();
38.    System.out.println("----程序结束运行----，程序运行时间【"
39.      + (date2.getTime() - date1.getTime()) + "毫秒】");
40. }
41. }
43. class MyCallable implements Callable<Object> {
44. private String taskNum;
46. MyCallable(String taskNum) {
47.    this.taskNum = taskNum;
48. }
50. public Object call() throws Exception {
51.    System.out.println(">>>" + taskNum + "任务启动");
52.    Date dateTmp1 = new Date();
53.    Thread.sleep(1000);
54.    Date dateTmp2 = new Date();
55.    long time = dateTmp2.getTime() - dateTmp1.getTime();
56.    System.out.println(">>>" + taskNum + "任务终止");
57.    return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";
58. }
59. }

复制代码

 
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！