标签：String Thread 创建 start 三种 new 线程 public

线程实现

线程的创建(三种方式)

1.继承 Thread 类（重要）

自定义线程类继承Thread类；

重写run()方法，编写线程执行体；

创建线程对象，调用start()方法启动线程。

package com.gcbeen.thread;

// 创建线程方式一：继承Thread类，重写run()方法，调用start开启线程
public class TestThread extends Thread {

    // run()方法线程体
    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println("我在阅读代码-----" + i);
        }
    }

    // main线程
    public static void main(String[] args) {
        // 创建一个线程对象
        TestThread thread = new TestThread();
        // 调用start()开启线程
        thread.start();

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

}

// 我在阅读代码-----5
// 多线程学习中……1
// 我在阅读代码-----6
// 我在阅读代码-----7
// 我在阅读代码-----8
// 多线程学习中……2
// 我在阅读代码-----9

线程不一定立即执行，由 CPU 安排调度。

package com.gcbeen.thread;

import org.apache.commons.io.FileUtils;

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

// 练习Thread，实现多线程同步下载图片
public class TestThread02 extends Thread {
    private String url;
    private String name;

    // 有参构造
    public TestThread02(String url, String name) {
        this.url = url;
        this.name = name;
    }

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

    public static void main(String[] args) {
        TestThread02 t1 = new TestThread02("http://browser9.qhimg.com/bdm/768_474_0/t010824ab8b5cdfa138.jpg", "str.png");
        TestThread02 t2 = new TestThread02("http://browser9.qhimg.com/bdm/768_474_0/t012468d019e3ce466b.jpg", "str2.png");
        TestThread02 t3 = new TestThread02("http://browser9.qhimg.com/bdm/384_237_0/t01039b44f7c7ca5ca3.jpg", "str3.png");

        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下载方法异常");
        }
    }
}

// 下载的文件：str2.png
// 下载的文件：str.png
// 下载的文件：str3.png

如果没有FileUtils.copyURLToFile方法，可以在maven官网下载jar包，按照下图导入即可。

在这里插入图片描述

2.实现Runnable接口

推荐使用Runnable对象, 因为Java单继承的局限性；

自定义线程类实现Runnable接口；

实现run()方法,编写线程执行体；

创建线程对象,调用start()方法启动对象。

package com.gcbeen.thread;

// 练习Thread，实现多线程同步下载图片
public class TestThread03 implements Runnable{

    @Override
    public void run() {
        // run方法线程体
        for (int i = 0; i < 20; i++) {
            System.out.println("我在看代码-----" + i);
        }
    }

    public static void main(String[] args) {
        // 创建runnable接口的实现类对象
        TestThread03 thread03 = new TestThread03();

        // 创建线程对象，通过线程对象来开启我们的线程，代理
        Thread thread = new Thread(thread03);

        // 调用start()开启线程
        thread.start();

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


// 我在看代码-----4
// 我在学习多线程……0
// 我在看代码-----5
// 我在看代码-----6
// 我在看代码-----7
// 我在看代码-----8
// 我在看代码-----9
// 我在看代码-----10
// 我在学习多线程……1
// 我在看代码-----11
// 我在学习多线程……2
// 我在看代码-----12

多个线程同时操作同一个对象买火车票案例
发现问题:多个线程操作同一个资源的情况下,线程不安全,数据紊乱

package com.gcbeen.thread;

// 多个线程同时操作同一个对象  买火车票案例

// 发现问题:多个线程操作同一个资源的情况下,线程不安全,数据紊乱
public class TestThread04 implements Runnable {
    // 票数
    private int ticketNums = 10;

    public static void main(String[] args) {
        TestThread04 thread04 = new TestThread04();
        new Thread(thread04, "张三").start();
        new Thread(thread04, "李四").start();
        new Thread(thread04, "王五").start();
        new Thread(thread04, "赵六").start();

    }

    @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-- + "张票");
        }
    }
}

// 
// 赵六---》拿到了第1张票
// 王五---》拿到了第0张票
// 李四---》拿到了第-1张票
// 张三---》拿到了第-1张票
//

模拟龟兔赛跑

package com.gcbeen.thread;


public class TestThread05 implements Runnable {
    // 胜利者
    private static String winner;

    public static void main(String[] args) {
        TestThread05 thread05 = new TestThread05();
        new Thread(thread05, "兔子").start();
        new Thread(thread05, "乌龟").start();
    }

    @Override
    public void run() {
        for (int i = 0; i <= 100; i++) {
            // 模拟兔子休息
            if (Thread.currentThread().getName().equals("兔子") && i % 10 == 0) {
                try {
                    Thread.sleep(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            // 判断比赛是否结束
            boolean flag = gameOver(i);
            // 如果比赛结束，停止程序
            if (flag) {
                break;
            }
            System.out.println(Thread.currentThread().getName() + "---》跑了" + i + "步");
        }
    }

    // 判断比赛是否结束
    private boolean gameOver(int steps) {
        if (winner != null) {
            return true;
        } else {
            if (steps >= 100) {   // 一共100步
                winner = Thread.currentThread().getName();
                System.out.println("winner is " + winner);
                return true;
            }
        }
        return false;
    }
}
// 
// 乌龟---》跑了96步
// 乌龟---》跑了97步
// 乌龟---》跑了98步
// 乌龟---》跑了99步
// 兔子---》跑了20步
// winner is 乌龟
// 
//

3.实现Callable接口（了解）

实现Callable接口，需要返回值类型；

重写call方法，需要抛出异常；

创建目标对象；

创建执行服务：ExecutorService ser = Executors.newFixedThreadPool(1);

提交执行：Future result1 = ser.submit(11);

获取结果：boolean r1 = result1.get();

关闭服务：ser.shutdownNow();

package com.gcbeen.thread;

import java.util.concurrent.*;

// 图片下载案例
public class TestThread06 implements Callable<Boolean> {
    private String url;     // 网络图片地址
    private String name;    // 报错的文件名

    // 有参构造
    public TestThread06(String url, String name) {
        this.url = url;
        this.name = name;
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        TestThread06 p1 = new TestThread06("http://browser9.qhimg.com/bdm/768_474_0/t010824ab8b5cdfa138.jpg", "ptr.png");
        TestThread06 p2 = new TestThread06("http://browser9.qhimg.com/bdm/768_474_0/t012468d019e3ce466b.jpg", "ptr02.png");
        TestThread06 p3 = new TestThread06("http://browser9.qhimg.com/bdm/384_237_0/t01039b44f7c7ca5ca3.jpg", "ptr03.png");

        // 执行服务
        ExecutorService service = Executors.newFixedThreadPool(3);

        // 提交执行
        Future<Boolean> submit = service.submit(p1);
        Future<Boolean> submit1 = service.submit(p2);
        Future<Boolean> submit2 = service.submit(p3);

        // 获取结果
        boolean aBoolean = submit.get();
        boolean aBoolean1 = submit1.get();
        boolean aBoolean2 = submit2.get();

        // 关闭服务
        service.shutdownNow();
    }

    // 下载图片线程的执行体
    @Override
    public Boolean call() throws Exception {
        WebDownloader webDownloader = new WebDownloader();
        webDownloader.downloader(url, name);
        System.out.println("下载的文件：" + name);
        return true;
    }
}


// 下载的文件：ptr02.png
// 下载的文件：ptr03.png
// 下载的文件：ptr.png

Thread 和 Runnable对比

继承Thred类:

子类继承Thread类具备多线程能力；
启动线程:子类对象.start()；
不建议使用:避免OOP单继承局限性。

实现Runnable接口

实现接口Runnable具有多线程能力；
启动线程:传入目标对象+Thread对象.start()；
推荐使用:避免单继承局限性,灵活方便,方便同一个对象被多个线程使用。

标签：String,Thread,创建,start,三种,new,线程,public
From： https://www.cnblogs.com/gcbeen/p/16743646.html

线程的实现-线程的创建(三种方式)