Java多线程01:创建新的执行线程

2022-08-15 00:00:00 创建 线程 多线程

创建新的执行线程(thread、Runnable)

核心概念

  • 线程就是独立的执行路径
  • 在程序运行时,即使没有自己创建线程,后台也会有多个线程,如主线程,gc线程.
  • main()称之为主线程,为系统的入口,用于执行整个程序
  • 在一个进程中,如果开辟了多个线程,线程的运行由调度器安排调度,调度器是与操作系统紧密相关的,先后顺序是不能人为的干预的.
  • 对同一份资源操作时,会存在资源抢夺的问题,需要加入并发控制.
  • 线程会带来额外的开销,如cpu调度时间, 并发控制开销.
  • 每个线程在自己的工作内存交互,内存控制不当会造成数据不一致.

线程创建(thread)

  • 继承Thread类

  • 重写run方法

  • 调用start开启线程

    //学习内容:
    //开发时间:2022/4/1 11:38
    package com.he.demo01;
    
    public class TestThread extends Thread{ 
        @Override
        public void run() { 
            super.run();
            //run方法线程体
            for (int i = 0; i < 200; i++) { 
                System.out.println("多线程---"+i);
            }
        }
    
        public static void main(String[] args) { 
            //main线程,主线程
    
            //创建一个线程对象
            TestThread testThread1 = new TestThread();
    
            //调用start方法开启线程
            testThread1.start();
            for (int i = 0; i < 1000; i++) { 
                System.out.println("我在学习多线程--"+i);
    
            }
        }
    }
    

实现Runnable

  • 创建一个新的执行线程有两种方法。 一个是将一个类声明为Thread的子类。 这个子类应该重写run类的方法Thread 。 然后可以分配并启动子类的实例。
  • 另一种方法来创建一个线程是声明实现类Runnable接口。 那个类然后实现了run方法。 然后可以分配类的实例,在创建Thread时作为参数传递,并启动。
//学习内容:
//开发时间:2022/4/11 19:25
package com.he.demo01;
//创建线程方法2:实现runnable接口,重写run方法,执行线程需要丢入runnable接口实现类,调用start方法
public class TestThread3 implements Runnable { 
    @Override
    public void run() { 

        //run方法线程体
        for (int i = 0; i < 200; i++) { 
            System.out.println("多线程---"+i);
        }
    }

    public static void main(String[] args) { 
       //创建runnable接口的实现类对象
        TestThread3 testThread3 = new TestThread3();
        //创建线程对象,通过线程对象来开启线程,代理
     /* Thread thread = new Thread(testThread3); thread.start();*/
     //这两行代码等于下面一行代码
        new Thread(testThread3).start();
        for (int i = 0; i < 1000; i++) { 
            System.out.println("我在学习多线程--"+i);

        }
    }
}

网图下载:

引用jar包:commons-io-2.7

推荐下载地址:https://commons.apache.org/proper/commons-io/

  • 先引入jar包

继承thread

//学习内容:
//开发时间:2022/4/11  17:08
package com.he.demo01;

import org.apache.commons.io.FileUtils;

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

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

    //构造器
    public TestThread2(String url,String name){
        this.url = url;
        this.name = name;

    }


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

    public static void main(String[] args) {
        TestThread2 t1 = new TestThread2("https://img-blog.csdnimg.cn/20201209131623572.png#pic_center","1.jpg");
        TestThread2 t2 = new TestThread2("https://profile-avatar.csdnimg.cn/d7969f1d77c343dd96d350c82e715c6d_weixin_45869823.jpg!1","2.jpg");
        TestThread2 t3 = new TestThread2("https://img-home.csdnimg.cn/images/20211223040118.png","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方法出现异常");
        }
    }
}

实现runnable接口时改部分代码(12行、38,39,40行)

改后如下:

//学习内容:
//开发时间:2022/4/11  17:08
package com.he.demo01;

import org.apache.commons.io.FileUtils;

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

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

    //构造器
    public TestThread2(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) {
        TestThread2 t1 = new TestThread2("https://img-blog.csdnimg.cn/20201209131623572.png#pic_center","1.jpg");
        TestThread2 t2 = new TestThread2("https://profile-avatar.csdnimg.cn/d7969f1d77c343dd96d350c82e715c6d_weixin_45869823.jpg!1","2.jpg");
        TestThread2 t3 = new TestThread2("https://img-home.csdnimg.cn/images/20211223040118.png","3.jpg");

        new Thread(t1).start();
        new Thread(t2).start();
        new Thread(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方法出现异常");
        }
    }
}

继承Thread类

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

实现Runnable接口

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

注意:线程开启不一定立即执行,由cpu调度执行

    原文作者:金士曼
    原文地址: https://blog.csdn.net/weixin_45869823/article/details/124330558
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。

相关文章