请选择 进入手机版 | 继续访问电脑版

极客┃做最好的游戏行业交流论坛

QQ登录

只需一步，快速开始

分享

三郎之——Java【多线程】

[复制链接]

三郎之——Java【多线程】

发表于 2022-1-12 14:18:22 只看大图 阅读模式 正序浏览
1576 0 查看全部

  2. 大家好划水的三郎更新多线程了多多指点欢迎大家留言讨论
复制代码
目录
线程概述
        进程介绍
        线程介绍
创建线程的三种方式
        1.继承Thread
        2.实现Runnable接口
        3.实现Callable接口
线程的六种状态
        线程执行状态流程图
        1.NEW
        2.RUNNABLE
        3.BLOCKED
        4.WAITING
        5.TIMED_WAITING
        6.TERMINATED
        状态测试代码块
实现抢票功能
        多线程带来的问题
        解决方法
Java中文文档
线程概述　　在跑步的过程之中做了些什么事情看进程介绍和线程介绍理解多线程。
进程介绍　　进程是计算机中的程序关于某数据集合上的一次运行活动是系统进行资源分配和调度的基本单位是操作系统结构的基础。比如美女去跑步了这一件事的整个过程。
线程介绍　　线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中是进程中的实际运作单位。一个进程中可以并发多个线程每条线程并行执行不同的任务。比如我们在跑步这个过程中同时做的事情例如呼吸听歌摆POSS等等这就是多线程。
创建线程的三种方式 1.继承Thread　　重点继承Thread类重写run方法run方法里面是线程体也就是新线程的入口调用start方法启动线程。启动方式线程对象.start方法。

  2. 测试过程创建StudyCSDNThread类继承Thread类重写run方法创建主线程main主函数执行程序run方法里面是一个for循环调用start方法之后启动线程由CPU就行调度不归我们管了让CPU自己去分配运行。
  3. [code]package com.example.demo.test;

  5. //继承Thread类
  6. public class StudyCSDNThread extends Thread{
  7.     //重写run方法新线程的入口
  8.     @Override
  9.     public void run() {
  10.         for (int i = 0; i ‹ 5; i++) {
  11.             System.out.println("文章对您有用的话点赞关注支持一下"+(i+1));
  12.         }
  13.     }

  15.     public static void main(String[] args) {
  16.         //创建一个线程对象
  17.         StudyCSDNThread studyCSDNThread = new StudyCSDNThread();
  18.         //调用start方法开启线程
  19.         studyCSDNThread.start();

  21.         for (int i = 0; i ‹ 5; i++) {
  22.             System.out.println("三郎学习多线程"+(i+1));
  23.         }
  24.     }
  25. }
复制代码

  运行结果如下线程由CPU调度每次执行结果都会不同不必多疑。
  1. 三郎学习多线程1
  2. 文章对您有用的话点赞关注支持一下1
  3. 文章对您有用的话点赞关注支持一下2
  4. 文章对您有用的话点赞关注支持一下3
  5. 三郎学习多线程2
  6. 文章对您有用的话点赞关注支持一下4
  7. 三郎学习多线程3
  8. 文章对您有用的话点赞关注支持一下5
  9. 三郎学习多线程4
  10. 三郎学习多线程5
复制代码

总结线程调用start方法开启之后未必执行由CPU进行调度看CPU心情。
[/code] 2.实现Runnable接口　　重点实现Runnable接口重写run方法run方法里面是线程体也就是新线程的入口调用start方法启动线程。启动方式new Thread(线程对象).start方法。

  2. 测试过程创建StudyCSDNRunnable类实现Runnable接口重写run方法创建主线程main主函数执行程序run方法里面是一个for循环只有Thread类有start方法通过new Thread调用start方法之后启动线程由CPU就行调度不归我们管了让CPU自己去分配运行。
  3. [code]package com.example.demo.test;

  5. //实现Runnable接口
  6. public class StudyCSDNRunnable implements Runnable{
  7.     //重写run方法
  8.     @Override
  9.     public void run() {
  10.         for (int i = 0; i ‹ 5; i++) {
  11.             System.out.println("文章对您有用的话点赞关注支持一下"+(i+1));
  12.         }
  13.     }
  14.     //主线程
  15.     public static void main(String[] args) {
  16.         //创建一个线程对象
  17.         StudyCSDNRunnable studyCSDNRunnable = new StudyCSDNRunnable();
  18.         //只有Thread才有start方法,new Thread(),放入我们的线程对象。调用start方法
  19.         new Thread(studyCSDNRunnable).start();
  20.         for (int i = 0; i ‹ 5; i++) {
  21.             System.out.println("三郎学习多线程"+(i+1));
  22.         }
  23.     }
  24. }
复制代码

运行结果如下跟方式一 一样线程由CPU进行调度每次执行接口都可能不一样。
  1. 三郎学习多线程1
  2. 文章对您有用的话点赞关注支持一下1
  3. 三郎学习多线程2
  4. 文章对您有用的话点赞关注支持一下2
  5. 三郎学习多线程3
  6. 文章对您有用的话点赞关注支持一下3
  7. 三郎学习多线程4
  8. 文章对您有用的话点赞关注支持一下4
  9. 文章对您有用的话点赞关注支持一下5
  10. 三郎学习多线程5
复制代码

总结推荐使用Runnable可摆脱Java单继承的局限性。线程调用start方法开启之后未必执行由CPU进行调度看CPU心情。
[/code] 3.实现Callable接口　　了解即可实现callable接口,需要返回值给一个返回值类型String,不写默认Object重写call方法会抛出一个异常 throws Exception。

  2.   测试过程创建StudyCSDNCallable类实现Callable接口重写call方法创建主线程main主函数执行程序创建线程池执行线程获取运行结果关闭线程池。
  3. [code]package com.example.demo.test;

  5. import java.util.concurrent.*;

  7. //实现callable接口,需要返回值给一个返回值类型String,不写默认Object
  8. public class StudyCSDNCallable implements Callable‹String> {
  9.     private String name;
  10.     private String study;
  11.     //构造方法
  12.     public StudyCSDNCallable(String name, String study) {
  13.         this.name = name;
  14.         this.study = study;
  15.     }
  16.     //重写call方法会抛出一个异常 throws Exception
  17.     @Override
  18.     public String call() throws Exception {
  19.         //输出可以看到是多线程执行
  20.         System.out.println(study);
  21.         //返回值
  22.         return name+study;
  23.     }
  24.     //主线程
  25.     public static void main(String[] args) throws ExecutionException,InterruptedException {
  26.         //传入两个参数看是否是多线程执行
  27.         StudyCSDNCallable studyCSDNCallable1 = new StudyCSDNCallable("三郎===","3.1学习多线程");
  28.         StudyCSDNCallable studyCSDNCallable2 = new StudyCSDNCallable("三郎===","3.2实现callable");
  29.         //创建一个线程池放入两个线程线程池重点内容后续单独出一篇文章解释
  30.         ExecutorService executorService = Executors.newFixedThreadPool(2);
  31.         //执行线程
  32.         Future‹String> submit1 = executorService.submit(studyCSDNCallable1);
  33.         Future‹String> submit2 = executorService.submit(studyCSDNCallable2);
  34.         //运行结果
  35.         String zyj1 = submit1.get();
  36.         //打印运行结果
  37.         System.out.println(zyj1);
  38.         String zyj2 = submit2.get();
  39.         //打印运行结果
  40.         System.out.println(zyj2);
  41.         //关闭线程池
  42.         executorService.shutdown();

  44.     }
  45. }
复制代码

运行结果线程由CPU进行调度每次执行接口都可能不一样。文中使用的线程数少可以多试几次或者多来几个线程。
  1. 3.2实现callable
  2. 3.1学习多线程
  3. 三郎===3.1学习多线程
  4. 三郎===3.2实现callable
复制代码

总结非重点此了解即可。
[/code] 线程的六种状态

  2. 很多博客上都是五种状态但其实是六种初始状态运行状态也称就绪状态阻塞状态等待状态等待状态分为两种等待指定时间状态和等待状态还有终止状态。摘自翻译的Java中文官方文档文档在文章最后可下载由下载链接。
  3.   
复制代码
线程执行状态流程图　　图文详解
watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5ZCO56uv5LiJ6YOOQFpZSg==,size_20,color_FFFFFF,t_70,g_se,x_16.jpg
1.NEW　　初始状态尚未启动的线程的线程状态。
2.RUNNABLE　　运行状态就绪状态一个可运行的线程的线程状态。 由CPU决定CPU已经调度的话是运行状态就绪状态就是CPU还没有进行调度已经做好被调度的准备。
3.BLOCKED　　阻塞状态线程阻塞等待监视器锁的线程状态。
4.WAITING　　等待状态等待线程的线程状态。
5.TIMED_WAITING　　等待指定时间状态具有指定等待时间的等待线程的线程状态。
6.TERMINATED　　终止状态 终止线程的线程状态。 线程终止不可再次开启。
状态测试代码块

  2. [code]package com.example.demo.test;

  4. public class StudyCSDNState implements Runnable{

  6.     public synchronized static void main(String[] args) throws InterruptedException {
  7.         System.out.println("###---start---###");
  8.         System.out.println("===线程的创建-运行-终止===");
  9.         //创建线程对象
  10.         StudyCSDNState studyCSDNState = new StudyCSDNState();
  11.         //创建Thread方法
  12.         Thread thread = new Thread(studyCSDNState);
  13.         System.out.println("===没有调用start方法前当前线程的状态"+thread.getState());
  14.         //调用start方法
  15.         thread.start();
  16.         System.out.println("===调用start后线程状态"+thread.getState());
  17.         Thread.sleep(100);
  18.         System.out.println("===线程进入等待状态"+thread.getState());
  19.         Thread.sleep(2000);
  20.         System.out.println("===等待两秒查看线程状态"+thread.getState());
  21.         System.out.println("###---end---###");
  22.     }

  24.     @Override
  25.     public void run() {
  26.         try {
  27.             Thread.sleep(1000);
  28.         } catch (InterruptedException e) {
  29.             e.printStackTrace();
  30.         }
  31.     }
  32. }
复制代码

运行结果如下
  1. ###---start---###
  2. ===线程的创建-运行-终止===
  3. ===没有调用start方法前当前线程的状态NEW
  4. ===调用start后线程状态RUNNABLE
  5. ===线程进入等待状态TIMED_WAITING
  6. ===等待两秒查看线程状态TERMINATED
  7. ###---end---###
复制代码

[/code] 实现抢票功能　　一共有10张车票创建了三个不同的对象来抢购。
多线程带来的问题

  2. 当多个线程操作同一对象的时候就会有抢错负数抢到同一张等的情况发生下面代码是抢错的代码可试验一下。
  3. [code]package com.example.demo.test;

  5. /**
  6. *多个线程操作同一个对象
  7. *买火车票为例子
  8. *
  9. * 发现问题多个线程操作同一个对象线程不安全了数据混乱
  10. *
  11. */
  12. public class StudyRunnable2 implements Runnable{

  14.     //10张车票
  15.     private Integer fare = 10;
  16.     private Boolean change = true;

  18.     @Override
  19.     public void run() {
  20.         while (change){
  21.             try {
  22.                 zyj();
  23.             } catch (InterruptedException e) {
  24.                 e.printStackTrace();
  25.             }
  26.         }
  27.     }

  29.     public void zyj() throws InterruptedException {
  30.             if(fare‹=0){
  31.                 change = false;
  32.                 return;
  33.             }
  34.             Thread.sleep(100);
  35.             System.out.println(Thread.currentThread().getName()+"----->拿到了第"+fare--+"票");
  36.     }

  38.     public static void main(String[] args) {
  39.         //单线程执行没有问题多线程执行出现问题
  40.         StudyRunnable2 studyRunnable2 = new StudyRunnable2();
  41.         new Thread(studyRunnable2,"张三").start();
  42.         new Thread(studyRunnable2,"李四").start();
  43.         new Thread(studyRunnable2,"王五").start();
  44.     }

  46. }
复制代码

[/code] 解决方法

  2. 使用synchronized关键字修饰由于java的每个对象都有一个内置锁当用此关键字修饰方法时 内置锁会保护整个方法。在调用该方法前需要获得内置锁否则就处于阻塞状态。
  3. 修改上边的代码找到zyj()方法在此方法加上synchronized即可修改的代码如下
  4. [code]public synchronized void zyj() throws InterruptedException {
  5.             if(fare‹=0){
  6.                 change = false;
  7.                 return;
  8.             }
  9.             Thread.sleep(100);
  10.             System.out.println(Thread.currentThread().getName()+"----->拿到了第"+fare--+"票");
  11.     }
复制代码

运行结果运行出来若都是一个人拿到的话多运行几次这个CPU决定的。
  1. 张三----->拿到了第10票
  2. 张三----->拿到了第9票
  3. 张三----->拿到了第8票
  4. 张三----->拿到了第7票
  5. 张三----->拿到了第6票
  6. 张三----->拿到了第5票
  7. 张三----->拿到了第4票
  8. 李四----->拿到了第3票
  9. 李四----->拿到了第2票
  10. 王五----->拿到了第1票
复制代码

  总结使用synchronized会影响效率不使用会导致数据混乱在数据安全方面还是舍弃效率吧synchronized最好加在修改数据的方法上可以少影响点效率。
注:产品改需求了............此处省略一万字.........得写代码了线程池等后续单独出一篇。
[/code] Java中文文档　　百度网盘链接https://pan.baidu.com/s/124_gXmqRs5Ng8LUW_Buq8A
提取码i6i8

来源：CSDN
三郎, ——, java, 多线程, 线程

相关帖子
回复

使用道具 举报

游客~
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

Geekpeer

管理员

  • 主题

    1386

  • 帖子

    2206

  • 粉丝

    32

+ 关注 发私信
Ta的新帖

Archiver|手机版|小黑屋|极客同行 ( 蜀ICP备17009389号-1 )

© 2013-2016 Comsenz Inc. Powered by Discuz! X3.4