Java三种实现多线程的方式

我不是女神ヾ 2023-09-29 17:33 8阅读 0赞

#### 文章目录 ####

*  一、继承Thread类
 *   *  1.1 简单的多线程示例
     *  1.2 多线程下载器
 *  二、实现Runnable接口
 *   *  2.1 Runnable的优点
     *  2.2将上面的两个Thread例子改为使用Runnable接口实现
     *  2.3 多个线程操作同一个对象
 *  三、实现Callable接口

## 一、继承Thread类 ##

> 1.  继承Thread类
> 2.  重写run方法
> 3.  创建Thread对象，执行start()方法

这样就有多条线程（main和run)并发执行了。

### 1.1 简单的多线程示例 ###

**`TestThread.java`**

public class TestThreading extends Thread{
        
        @Override
        public void run() {
        
            // TODO Auto-generated method stub
            for (int i = 0; i < 3000; i++){
        
                System.out.println("我在抽烟！");
            }
        }
    
        public static void main(String[] args) {
        
            TestThreading thread = new TestThreading();
            thread.start();
            for (int i = 0; i < 400; i++){
        
                System.out.println("我在拉屎");
            }
        }
    }

**`嗨嗨害，这样我就可以一边抽烟一边拉屎了`**

### 1.2 多线程下载器 ###

下载器使用[commons-io-2.11.0.jar][]，导入依赖，然后`import org.apache.commons.io.FileUtils`  
这里演示多线程下载三张图片。

**`TestThreading2.java`**

package com.peng.demo02;
    
    import java.io.File;
    import java.io.IOException;
    import java.net.URL;
    
    import org.apache.commons.io.FileUtils;
    public class TestThreading2 extends Thread{
        
        private String url;
        private String filename;
    
        public TestThreading2(String url, String filename){
        
            this.url = url;
            this.filename = filename;
        }
        @Override
        public void run() {
        
            WebDownloader downloader = new WebDownloader();
            downloader.download(url, filename);
            System.out.println("下载的图片为：" + filename);
        }
    
        public static void main(String[] args) {
        
            TestThreading2 thread1 = new TestThreading2(	"https://img0.baidu.com/it/u=3756363057,4015279587&fm=253&fmt=auto&app=120&f=JPEG?w=1135&h=735", "张嘉文.jpeg");
            TestThreading2 thread2 = new TestThreading2("https://img2.baidu.com/it/u=1727704756,953533183&fm=253&fmt=auto&app=120&f=JPEG?w=587&h=349", "狐臭佬.jpeg");
            TestThreading2 thread3 = new TestThreading2("https://img2.baidu.com/it/u=2388598882,3415168598&fm=253&fmt=auto&app=138&f=JPEG?w=471&h=500", "药水哥.jpeg");
    
            thread1.start();
            thread2.start();
            thread3.start();
        }
    
    }
    
    // 下载器
    class WebDownloader{
        
        //下载方法
        public void download(String url, String filename){
        
            try {
        
                FileUtils.copyURLToFile(new URL(url), new File(filename), 10000, 10000);
            } catch (IOException e) {
        
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("下载器方法异常!");
            }
        }
    }

## 二、实现Runnable接口 ##

*  实现步骤：

> 创建一个类实现Runnable接口并重写run()方法 -->  
> 创建实例对象，然后放入Thread()参数中，start()线程。

### 2.1 Runnable的优点 ###

*  推荐使用实现Runnable接口的这种多线程实现方式
 *  避免了JAVA单继承的局限性
 *  方便同一个对象被多个线程使用  
      
    \\

### 2.2将上面的两个Thread例子改为使用Runnable接口实现 ###

**`TestThreading3.java`**

package com.peng.demo03;
    
    // 这里实现了Runnable接口
    public class TestThreading3 implements Runnable{
        
    
        @Override
        public void run() {
        
            // TODO Auto-generated method stub
            for (int i = 0; i<3000; i++){
        
                System.out.println("我在抽烟！");
            }
        }
    	
        public static void main(String[] args) {
        
        	// 创建实例对象
            TestThreading3 tt3 = new TestThreading3();
            // 对象作为Thread参数，同时开启线程
            new Thread(tt3).start();
    
            for (int i = 0; i < 400; i++){
        
                System.out.println("我在拉屎");
            }
        }
        
    }

**`TestThreading4.java`**

package com.peng.demo02;
    
    import java.io.File;
    import java.io.IOException;
    import java.net.URL;
    
    import org.apache.commons.io.FileUtils;
    public class TestThreading4 implements Runnable{
        
        private String url;
        private String filename;
    
        public TestThreading4(String url, String filename){
        
            this.url = url;
            this.filename = filename;
        }
        @Override
        public void run() {
        
            WebDownloader downloader = new WebDownloader();
            downloader.download(url, filename);
            System.out.println("下载的图片为：" + filename);
        }
    
        public static void main(String[] args) {
        
            TestThreading4 thread1 = new TestThreading4(	"https://img0.baidu.com/it/u=3756363057,4015279587&fm=253&fmt=auto&app=120&f=JPEG?w=1135&h=735", "张嘉文.jpeg");
            TestThreading4 thread2 = new TestThreading4("https://img2.baidu.com/it/u=1727704756,953533183&fm=253&fmt=auto&app=120&f=JPEG?w=587&h=349", "狐臭佬.jpeg");
            TestThreading4 thread3 = new TestThreading4("https://img2.baidu.com/it/u=2388598882,3415168598&fm=253&fmt=auto&app=138&f=JPEG?w=471&h=500", "药水哥.jpeg");
    
            // thread1.start();
            // thread2.start();
            // thread3.start();
            new Thread(thread1).start();
            new Thread(thread2).start();
            new Thread(thread3).start();
        }
    
    }
    
    // 下载器
    class WebDownloader{
        
        //下载方法
        public void download(String url, String filename){
        
            try {
        
                FileUtils.copyURLToFile(new URL(url), new File(filename), 10000, 10000);
            } catch (IOException e) {
        
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("下载器方法异常!");
            }
        }
    }

### 2.3 多个线程操作同一个对象 ###

这里模拟一个多线程抢票的情景。  
后面还需要解决同步的问题。

package com.peng.demo03;
    
    public class TestThreading4 implements Runnable{
        
        private int ticketNumber = 10;
    
        @Override
        public void run() {
        
            // 抢票
            while (true){
        
                if (ticketNumber <= 0){
        
                    break;
                }
    
                try {
        
                    Thread.sleep(200);
                } catch (InterruptedException e) {
        
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + " 抢到了第 "+ ticketNumber-- +" 张票");
            }
        }
    
        public static void main(String[] args) {
        
            TestThreading4 tt4 = new TestThreading4();
            //开启线程
            // 这里三个黄牛抢票，嘿嘿。多个线程操作同一个对象
            new Thread(tt4, "小明").start();
            new Thread(tt4, "老师").start();
            new Thread(tt4, "黄牛").start();
            new Thread(tt4, "黄牛").start();
            new Thread(tt4, "黄牛").start();
        }
    }

## 三、实现Callable接口 ##

*  和实现Runnable接口类似，但是Callable功能更全，**`带有返回值，可以抛出异常`**。
 *  实现Callable接口需要实现一个call()方法，这个是线程的执行内容

> **和Runnable相比，多了下面这几步骤**  
>   
>   `创建执行服务` \--> `提交执行` \--> `获取执行结果` \--> `关闭服务`

使用Callable接口实现一个多线程下载器的程序  
  
**TestCallable.java**

package com.peng.demo04;
    
    import java.io.File;
    import java.io.IOException;
    import java.net.URL;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    import org.apache.commons.io.FileUtils;
    
    public class TestCallable implements Callable<Boolean>{
        
        private String url;
        private String filename;
    
        TestCallable(String url, String filename){
        
            this.url = url;
            this.filename = filename;
        }
        @Override
        public Boolean call() throws Exception {
        
            WebDownloader download = new WebDownloader();
            download.download(url, filename);
            System.out.println("下载的图片为：" + filename);
            return true;
        }
    
        public static void main(String[] args) throws InterruptedException, ExecutionException {
        
            TestCallable thread1 = new TestCallable(	"https://img0.baidu.com/it/u=3756363057,4015279587&fm=253&fmt=auto&app=120&f=JPEG?w=1135&h=735", "张嘉文.jpeg");
            TestCallable thread2 = new TestCallable("https://img2.baidu.com/it/u=1727704756,953533183&fm=253&fmt=auto&app=120&f=JPEG?w=587&h=349", "狐臭佬.jpeg");
            TestCallable thread3 = new TestCallable("https://img2.baidu.com/it/u=2388598882,3415168598&fm=253&fmt=auto&app=138&f=JPEG?w=471&h=500", "药水哥.jpeg");
    
            // 1.创建执行服务
            ExecutorService ser = Executors.newFixedThreadPool(3);
            // 2.提交执行
            Future<Boolean> r1 = ser.submit(thread1);
            Future<Boolean> r2 = ser.submit(thread2);
            Future<Boolean> r3 = ser.submit(thread3);
            // 3.获取结果
            boolean rs1 = r1.get();
            boolean rs2 = r2.get();
            boolean rs3 = r3.get();
    
            System.out.println(rs1 + " " + rs2 + " " + rs3);
            // 4.关闭执行服务
            ser.shutdownNow();
            
        }
        
    }
    
    // 下载器
    class WebDownloader{
        
        public void download(String url, String filename){
        
            try {
        
                FileUtils.copyURLToFile(new URL(url), new File(filename), 10000, 10000);
            } catch (IOException e) {
        
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("下载器方法错误");
            }
        }
    }

[commons-io-2.11.0.jar]: http://123.60.108.111/file/commons-io-2.11.0.jar