多线程！！

Posted 2021-09-09 等慢慢

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了多线程！！相关的知识，希望对你有一定的参考价值。

多线程

Thread(线程)

简述：多条执行路径，主线程和子线程并行交替执行

三种创建线程的方式

1、继承Thread方法

自定义线程类继承Thread类
重写run()方法，编写线程执行体
创建线程对象，调用start()方法启动线程

package com.sgl.demo01;

//创建线程方式一：继承Thread类，重写run()方法，调用start开启线程
public class TestThread1 extends Thread{
    @Override
    public void run() {
        //run()方法线程体
        for (int i = 0; i < 200; i++) {
            System.out.println("我在看代码--"+i);
        }

    }

    public static void main(String[] args) {
        //main线程，主线程

        //创建一个线程对象
        TestThread1 testThread1 = new TestThread1();

        //调用start()方法开启线程
        testThread1.start();
        //testThread1.run();  //如果调用run()先执行run方法，在执行下面代码，一条执行路径


        for (int i = 0; i < 200; i++) {
            System.out.println("我在学习多线程--"+i);
        }
    }
}

运行结果：

注意：线程开启不一定执行，CPU调度执行；如果调用run()方法，先执行完run()方法，在执行后面代码，代码如下：

package com.sgl.demo01;

//创建线程方式一：继承Thread类，重写run()方法，调用start开启线程
public class TestThread1 extends Thread{
    @Override
    public void run() {
        //run()方法线程体
        for (int i = 0; i < 5; i++) {
            System.out.println("我在看代码--"+i);
        }

    }

    public static void main(String[] args) {
        //main线程，主线程

        //创建一个线程对象
        TestThread1 testThread1 = new TestThread1();

        //调用start()方法开启线程
        testThread1.run();


        for (int i = 0; i < 5; i++) {
            System.out.println("我在学习多线程--"+i);
        }
    }
}

运行结果：

网图下载案例：

package com.sgl.demo01;

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;

//实现多线程同步下载图片
public class TestThread2 extends Thread{
    String url;//网络图片地址
    String name;//保存的文件名

    public TestThread2(String url,String name){
        this.name = name;
        this.url = url;
    }

    //下载图片线程的执行体
    @Override
    public void run() {
        WebDownloader webDownloader = new WebDownloader();
        webDownloader.downloader(url,name);
        System.out.println("下载了文件名为:"+name);

    }

    public static void main(String[] args) {
        TestThread2 t1 = new TestThread2("https://p2.ssl.qhimgs1.com/sdr/400__/t013fdffe8885b2e998.jpg","1.jpg");
        TestThread2 t2 = new TestThread2("https://p1.ssl.qhimgs1.com/sdr/400__/t01509b0aea5472d44b.jpg","2.jpg");
        TestThread2 t3 = new TestThread2("https://p0.ssl.qhimgs1.com/sdr/400__/t019289d43a43cb057e.jpg","3.jpg");

        t1.start();
        t2.start();
        t3.start();
    }
}

//下载器
class WebDownloader{
    //下载方法
    public void downloader(String url,String name){
        try {
            FileUtils.copyURLToFile(new URL(url),new File(name));
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("IO异常，downloader方法出现异常");
        }
    }
}

2、Runnable接口(实现Runnable接口)

自定义类实现Runnable接口
实现run()方法，编写线程执行体
创建线程对象，调用start()方法启动线程

package com.sgl.demo01;

//自定义类实现Runnable接口
public class TestThread1 implements Runnable{
    @Override
    public void run() {
        //run()方法线程体
        for (int i = 0; i < 5; i++) {
            System.out.println("我在看代码--"+i);
        }

    }

    public static void main(String[] args) {
        //main线程，主线程
        
        //创建实现类对象
        TestThread1 testThread1 = new TestThread1();

        //创建代理类对象传入实现类对象，并调用start()方法开启线程
        new Thread(testThread1).start();


        for (int i = 0; i < 5; i++) {
            System.out.println("我在学习多线程--"+i);
        }
    }
}

网图下载案例：

package com.sgl.demo01;

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;

//实现多线程同步下载图片
public class TestThread2 implements Runnable{
    String url;//网络图片地址
    String name;//保存的文件名

    public TestThread2(String url,String name){
        this.name = name;
        this.url = url;
    }

    //下载图片线程的执行体
    @Override
    public void run() {
        WebDownloader webDownloader = new WebDownloader();
        webDownloader.downloader(url,name);
        System.out.println("下载了文件名为:"+name);

    }

    public static void main(String[] args) {
        TestThread2 t1 = new TestThread2("https://p2.ssl.qhimgs1.com/sdr/400__/t013fdffe8885b2e998.jpg","1.jpg");
        TestThread2 t2 = new TestThread2("https://p1.ssl.qhimgs1.com/sdr/400__/t01509b0aea5472d44b.jpg","2.jpg");
        TestThread2 t3 = new TestThread2("https://p0.ssl.qhimgs1.com/sdr/400__/t019289d43a43cb057e.jpg","3.jpg");

        Thread thread1 = new Thread(t1);
        Thread thread2 = new Thread(t2);
        Thread thread3 = new Thread(t3);
        thread1.start();
        thread2.start();
        thread3.start();
    }
}

//下载器
class WebDownloader{
    //下载方法
    public void downloader(String url,String name){
        try {
            FileUtils.copyURLToFile(new URL(url),new File(name));
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("IO异常，downloader方法出现异常");
        }
    }
}

小结：

继承Thread类
1. 子类继承Thread类具备多线程能力
2. 启动线程：子类对象.start()
3. 不建议使用：避免OOP单继承局限性
实现Runnable接口
1. 实现Runnable接口具有多线程能力
2. 启动线程：传入目标对象+Thread对象.start()方法
3. 推荐使用：避免单继承局限性，灵活方便，方便同一个对象被多个线程使用

案例：

发现问题：多个线程操作同一个资源的情况下，线程不安全，数据紊乱

package com.sgl.demo01;

//发现问题：多个线程操作同一个资源的情况下，线程不安全，数据紊乱
public class TextThread4 implements Runnable{

    private int ticketNums = 10;//票数

    @Override
    public void run() {
        while (true){
            if (ticketNums < 0){
                break;
            }

            //模拟延时
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+"-->拿到了"+ticketNums--+"票");
        }
    }

    public static void main(String[] args) {
        TextThread4 ticket = new TextThread4();

        new Thread(ticket,"小明").start();
        new Thread(ticket,"小和").start();
        new Thread(ticket,"小杠").start();
    }
}

解决数据紊乱的问题，案例：

package com.sgl.demo01;

//模拟龟兔赛跑
public class Race implements Runnable{

    private static String winner;

    @Override
    public void run() {
        for (int i = 0; i <= 100; i++) {

//            //模拟兔子休息
//            if (Thread.currentThread().getName().equals("兔子") && i%10==0){
//                try {
//                    Thread.sleep(2);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//
//            }

            //判断比赛是否结束
            boolean flag = gameOver(i);
            if (flag){
                break;
            }

            System.out.println(Thread.currentThread().getName()+"-->跑了"+i+"步");
        }
    }

    //判断比赛是否结束
    private boolean gameOver(int step){
        //判断是否有胜利者
        if (winner!=null){//已经存在胜利者
            return true;
        }{
            if (step>=100){
                winner = Thread.currentThread().getName();
                System.out.println("winner is"+" "+winner);
                return true;
            }
        }
        return false;
    }

    public static void main(String[] args) {
        Race race = new Race();

        new Thread(race,"兔子").start();
        new Thread(race,"乌龟").start();
    }
}

3、Callable接口(实现Callable接口) 了解即可！！！

实现Callable接口，需要返回值类型
重写call()方法
创建目标对象
创建执行服务：ExecutorService ser = Executors.newFixedThreadPool(1)
提交执行Future result1 = ser.submit(t1)
获取结果：boolean r1 = result1.get()
关闭服务：ser.shutdownNow()

package com.sgl.demo01;

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.util.concurrent.*;

//创建方式：实现Callable接口
/*优点：
可以定义返回值类型
可以抛出异常
*/
public class TestCallable implements Callable<Boolean> {
    String url;//网络图片地址
    String name;//保存的文件名

    public TestCallable(String url, String name) {
        this.name = name;
        this.url = url;
    }
    
    @Override
    public Boolean call() {
        WebDownloader1 webDownloader1 = new WebDownloader1();
        webDownloader1.downloader(url, name);
        System.out.println("下载了文件名为:" + name);
        return true;
    }


    public static void main(String[] args) throws ExecutionException, InterruptedException {
        TestCallable t1 = new TestCallable("https://p2.ssl.qhimgs1.com/sdr/400__/t013fdffe8885b2e998.jpg", "1.jpg");
        TestCallable t2 = new TestCallable("https://p1.ssl.qhimgs1.com/sdr/400__/t01509b0aea5472d44b.jpg", "2.jpg");
        TestCallable t3 = new TestCallable("https://p0.ssl.qhimgs1.com/sdr/400__/t019289d43a43cb057e.jpg", "3.jpg");

        //1.创建执行服务
        ExecutorService ser = Executors.newFixedThreadPool(3);
        //2.提交执行
        Future<Boolean> result1 = ser.submit(t1);
        Future<Boolean> result2 = ser.submit(t2);
        Future<Boolean> result3 = ser.submit(t3);
        //3.获取结果
        boolean rs1 = result1.get();
        boolean rs2 = result2.get();
        boolean rs3 = result3.get();

        System.out.println(rs1);
        System.out.println(rs2);
        System.out.println(rs3);

        //4.关闭服务
        ser.shutdownNow();
    }
}


//下载器
class WebDownloader1{
    //下载方法
    public void downloader(String url,String name){
        try {
            FileUtils.copyURLToFile(new URL(url),new File(name));
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("IO异常，downloader方法出现异常");
        }
    }
}

静态代理模式

简述：

真实对象和代理对象都要实现一个接口
代理对象要代理真实角色
优点：
代理对象可以做很多真实对象做不了的事情
真实对象做自己专注的事情

package com.sgl.demo02;

/*
静态代理模式：
真实对象和代理对象都要实现一个接口
代理对象要代理真实角色
优点：
代理对象可以做很多真实对象做不了的事情
真实对象做自己专注的事情

 */
public class StaticProxy {
    public以上是关于多线程！！的主要内容，如果未能解决你的问题，请参考以下文章 
 线程学习知识点总结
 多个请求是多线程吗
 python小白学习记录 多线程爬取ts片段
 多线程编程
 多线程编程
 python多线程