Java教程

01多线程

本文主要是介绍01多线程,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

多线程

简介

创建线程

Thread class

  • 继承Thread类(重点)

1.自定义线程类继承Thread类

2.重写run()方法,编写线程执行体

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

package edu.wzw.Thread;
//创建线程方法:继承Thread类,重写run()方法,调用start开启线程
//总结:注意,线程开启不一定立即执行,由cpu调度执行
public class demo01 extends Thread{
    @Override
    public  void run (){//run()方法线程
        for (int i = 0; i < 20; i++) {
            System.out.println("你说得对"+i);
        }
    }
    public static void main(String[] args) {
        //main线程,主线程
        //创建一个线程对象
        demo01 demo01 = new demo01();
        //使用start()方法开启线程
        demo01.start();
        for (int i = 0; i < 20; i++) {
            System.out.println("你真是个大聪明"+i);
        }
    }
}

举例:下载网上图片

这里使用Maven,不使用Maven的话去导入io的包

<!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>2.9.0</version>
        </dependency>

主函数

package deu.wzw;
import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;
//练习Thrad,实现多线程下载图片
public class Threads extends Thread {
    private String url;//网络图片地址
    private String name;//保存的文件名

    public Threads(String url, String name) {
        this.url = url;
        this.name = name;
    }
    //下载图片线程的执行体
    public void run() {
        WebDownLoader webDownLoader = new WebDownLoader();
        webDownLoader.downloder(url, name);
        System.out.println("文件名" + name);

    }

    public static void main(String[] args) {
        Threads t1 = new Threads("https://ss0.baidu.com/-Po3dSag_xI4khGko9WTAnF6hhy/zhidao/wh%3D450%2C600/sign=f491e04833fae6cd0ce1a3653a832312/bd315c6034a85edfee0bff5c4f540923dc5475cd.jpg", "1.jpg");
        t1.start();
    }
}
//下载器
class WebDownLoader{
    //下载方法
        public void downloder(String url,String name){
            try {
                FileUtils.copyURLToFile(new URL(url),new File(name));
            } catch (IOException e) {
                e.printStackTrace();
                System.out.println("IO异常,downloder方法出现异常");
            }
        }
}


unnable接口

  • 实现Runnable接口(核心重点)

1.定义MyRunnable实现Runnanle接口

2.实现Run()方法,编写线程执行体

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

package edu.wzw.Thread;

public class ThreadsRunnable implements Runnable {

    @Override
    public  void run (){//run()方法线程
        for (int i = 0; i < 20; i++) {
            System.out.println("我是你妈"+i);
        }
    }
    public static void main(String[] args) {
        ThreadsRunnable threadsRunnable = new ThreadsRunnable();
//        Thread thread = new Thread(threadsRunnable);
//        thread.start();  可以简写,如下
          new Thread(threadsRunnable).start();
          
        for (int i = 0; i < 20; i++) {
            System.out.println("我是你爹"+i);
        }
    }
}

Callable接口

  • 实现Callable接口
    • 实现Callable接口,需要返回值类型
    • 重写call方法,需要抛出异常
    • 创建目标对象
    • 创建执行服务:ExecutorService ser = Executors.newFixedThreadPool(1);
    • 提交执行:Futureresult1 = ser.submit()
    • 获取结果:boolean r1 = result.get();
    • 关闭服务:ser.shoutdownNow();

小结

  • 继承Thread类
    • 子类继承Thread类具备多线程能力
    • 启动线程:子类对象.start()
    • 不建议使用:避免OOP单继承局限性
  • 实现Runnable接口
    • 实现接口Runnable具有的多线程能力
    • 启动线程:传入目标对象+Thread对象.start()
    • 推荐使用:避免单继承局限性,灵活方便,方便同一个对象被多个线程使用
package edu.wzw.Thread;
//多线程同时操作一个对象
//买动车票的例子
//发现问题:多个线程操作同一个资源的情况下,线程不安全,数据紊乱。线程同步解决
public class Threaddemo02 implements Runnable{
    private int stickNum=10;//票数
    @Override
    public void run(){
        while(true){
            if (stickNum<=0){
                break;
            }//Thread.currentThread().getName()拿到线程的名字
        System.out.println(Thread.currentThread().getName()+"拿到了"+stickNum--+"票");
        }
    }

    public static void main(String[] args) {
        Threaddemo02 stick = new Threaddemo02();
        new Thread(stick,"wzw").start();
        new Thread(stick,"死黄牛").start();
    }
}

这篇关于01多线程的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!