首页 > 其他分享 >线程

线程

时间:2022-10-05 21:55:41浏览次数:39  
标签:name Thread 线程 new public String

线程

继承Thread类

package com.teatea.demo01;

//创建线程方程一:继承Threa类,重写run方法,调用start开启线程
public class TestThread1 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方法,主线程
        //创建一个线程对象
        TestThread1 testThread1 = new TestThread1();
        //调用start()方法开启线程
        testThread1.start();
        
        for (int i = 0; i < 20; i++) {
            System.out.println("我在学习多线程---"+i);
        }
    }
}

实例—网图下载代码

package com.teatea.demo01;

import org.apache.commons.io.FileUtils;

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

//练习Thread,实现多线程同步下载图片
//2.继承类,编写构造方法
public class TestThread2 extends Thread{
    private String url;
    private String name;

    public TestThread2(String url,String name){
        this.url = url;  //文件下载地址
        this.name = name;  //保存文件名
    }

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

    //4.线程启动
    public static void main(String[] args) {
        TestThread2 testThread2 = new TestThread2("https://pic1.zhimg.com/v2-7c168a484333f45b2315c9d1afa13d74_r.jpg?source=1940ef5c","图片2");
        TestThread2 testThread3 = new TestThread2("https://pic1.zhimg.com/v2-7c168a484333f45b2315c9d1afa13d74_r.jpg?source=1940ef5c","图片3");

        testThread2.start();
        testThread3.start();
    }
}

//1.下载器
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方法出现问题");
        }
    }
}

/*
1.写一个下载器,里面有下载方法
2.实现一个线程类,用TestThread2继承Thread类
用构造器丢入url,name
3.重写run方法
4.启动线程
 */

实现Runnable接口

package com.teatea.demo01;

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

    public static void main(String[] args) {
        //m创建Runnable接口的实现类对象
        TestThread3 testThread3 =new TestThread3();
        //创建线程对象,通过线程对象来开启我们的线程,代理
        Thread thread = new Thread(testThread3);

        thread.start();

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

实例—网图下载代码(Runnable接口)

package com.teatea.demo01;

import org.apache.commons.io.FileUtils;

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

//练习Thread,实现多线程同步下载图片
//2.继承类,编写构造方法
public class TestThread2 implements Runnable{
    private String url;
    private String name;

    public TestThread2(String url,String name){
        this.url = url;  //文件下载地址
        this.name = name;  //保存文件名
    }


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

    //4.线程启动
    public static void main(String[] args) {
        TestThread2 testThread2 = new TestThread2("https://pic1.zhimg.com/v2-7c168a484333f45b2315c9d1afa13d74_r.jpg?source=1940ef5c","图片2");
        TestThread2 testThread3 = new TestThread2("https://pic1.zhimg.com/v2-7c168a484333f45b2315c9d1afa13d74_r.jpg?source=1940ef5c","图片3");

        new Thread(testThread2).start();
        new Thread(testThread3).start();
    }
}

//1.下载器
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方法出现问题");
        }
    }
}

/*
1.写一个下载器,里面有下载方法
2.实现一个线程类,用TestThread2继承Thread类
用构造器丢入url,name
3.重写run方法
4.启动线程
 */

小结:两种代码对比

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

初始并发问题

package com.teatea.demo01;

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

//发现问题:多个线程操作同一个资源情况下,线程不安全了,数据紊乱
public class TestThread4 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();
            }
            //拿到线程当前执行线程的名字--->Thread.currentThread().getName()
            System.out.println(Thread.currentThread().getName()+"--->拿到了第"+ticketNums--+"票");
        }
    }

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

        new Thread(ticket,"小明").start();
        new Thread(ticket,"小红").start();
        new Thread(ticket,"小亮").start();
        new Thread(ticket,"小茶").start();
        new Thread(ticket,"小发").start();
    }
}

案例—龟兔赛跑

package com.teatea.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(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

            //判断比赛是否结束
            Boolean flag = gameOver(i);
            //如果比赛结束,就停止程序
            if (flag){
                break;
            }


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

    //判断是否完成比赛
    public boolean gameOver(int steps){
        //判断是否有胜利者
        if(winner!=null){//已经存在胜利者
            return true;
        }
        {
            if (steps >= 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();
    }
}

/*
步骤总结:
1.构造判断方法,判断是否有赢家
2.implement Runnable,重写run方法,判断比赛是否结束,true为停止,否则输出跑了多少步
3.给兔子制造延时
4.main方法启动线程
 */

标签:name,Thread,线程,new,public,String
From: https://www.cnblogs.com/bobocha/p/16756521.html

相关文章

  • 并发学习记录16:任务调度线程池
    在任务调度池功能加入之前,可以使用java.util.Timer来实现定时功能,Timer的优点在于简单易用,但由于所有任务都是由同一个线程来调度,因此所有任务都是串行执行的,同一时间只能......
  • Linux多线程服务端编程 pdf
    高清文字版下载链接:https://pan.baidu.com/s/1Ar0sbiycp70BdNysXfkg2w点击这里获取提取码 ......
  • 推荐一款工具,辅助估算线程池参数
    前言相信接触过并发系统的小伙伴们基本都使用过线程池,或多或少调整过对应的参数。以Java中的经典模型来说,能够配置核心线程数、最大线程数、队列容量等等参数。public......
  • 线程之间的通信
    一、为什么要线程通信?  1.多个线程并发执行时,在默认情况下CPU是随机切换线程的,当我们需要多个线程来共同完成一件任务, 并且我们希望他们有规律的执行,那么多线程......
  • 线程控制 fork
    线程控制1.线程控制1.1.并行线程1.2.一些代码示例1.2.1.多个initial并行执行1.2.2.单个initial内串行执行1.2.3.fork...join内并行执行1.2.4.join_any......
  • 线程间同步和通信,event semaphore mailbox
    线程间同步和通信,event semaphore mailbox1.概述2.事件event3.wait_order()4.旗语(semaphore)5.semaphore::get();6.semaphore::try_get()7.信箱mailbox......
  • 线程的控制与同步
    线程的控制与同步1.线程的使用1.1.什么是线程?1.2.线程的概念澄清2.线程的控制2.1.fork并行线程语句块2.2.等待所有衍生线程2.3.停止单个线程2.4.......
  • XX学Python·进程与线程
    多任务编程-进程多任务执行方式并发:在一段时间内交替去执行任务并行:多核cpu每个cpu执行一个任务。注:任务>cpu时,每个cpu并发执行多个任务进程:计算机中的程......
  • 进程和线程区别?
    文章目录进程和线程进程线程进程与线程的区别总结从JVM角度说进程和线程之间的关系(重要)图解进程和线程的关系程序计数器为什么是私有的?虚拟机栈和本......
  • 进程和线程的区别2
    进程和线程的区别 最佳答案进程是操作系统资源分配的基本单位,而线程是处理器任务调度和执行的基本单位。还存在资源开销、包含关系、内存分配、影响关系、执行过程等......