AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

多线程编程核心技术-java多线程技能（1）(上）

2022-10-09 125
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 多线程编程核心技术-java多线程技能（1）(上）

进程和多线程的概念以及线程的优点

1.进程概念



1dc618a0ed9580ce8bfa6facb208c08f.png


2.线程概念


5d4c6812c8535adbb050f4ddf2e1bce8.png


3.优点



46a9d80a6e05e4e3b19d57a0ee70bcdf.png


使用多线程

接触下线程


public class Demo1 {
    public static void main(String[] args) {
        System.out.println(Thread.currentThread().getName());
    }
}

66ba272a0bfc97be54a5fa679e3d5482.png


1.继承Thread类


代码运行和代码执行和调用顺序无关


自定义一个线程类:


public class MyThread extends Thread{
    @Override
    public void run() {
        super.run();
        System.out.println("Mythead");
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();
        System.out.println("运行结束!");
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png

5d4c6812c8535adbb050f4ddf2e1bce8.png


线程调用的随机性


public class RandomThread extends Thread {
    @Override
    public void run() {
        try {
            for (int i = 0; i < 10; i++) {
                int time = (int) (Math.random() * 1000);
                Thread.sleep(time);
                System.out.println("run==" + Thread.currentThread().getName());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        try {
            RandomThread randomThread = new RandomThread();
            randomThread.setName("myThread");
            randomThread.start();
            for (int i = 0; i < 10; i++) {
                int time = (int) (Math.random() * 1000);
                Thread.sleep(time);
                System.out.println("run==" + Thread.currentThread().getName());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("run==" + Thread.currentThread().getName());
    }
}

46a9d80a6e05e4e3b19d57a0ee70bcdf.png


66ba272a0bfc97be54a5fa679e3d5482.png


执行start方法的顺序不代表线程启动顺序


public class ThreadDemo extends Thread{
    private int i;
    public ThreadDemo(int i){
        super();
        this.i = i;
    }
    @Override
    public void run() {
        System.out.println(i);
    }
    public static void main(String[] args) {
        ThreadDemo t1 = new ThreadDemo(1);
        ThreadDemo t2 = new ThreadDemo(2);
        ThreadDemo t3 = new ThreadDemo(3);
        ThreadDemo t4 = new ThreadDemo(4);
        ThreadDemo t5 = new ThreadDemo(5);
        ThreadDemo t6 = new ThreadDemo(6);
        ThreadDemo t7 = new ThreadDemo(7);
        ThreadDemo t8 = new ThreadDemo(8);
        t1.start();
        t2.start();
        t3.start();
        t4.start();
        t5.start();
        t6.start();
        t7.start();
        t8.start();
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png


2.实现Runnable接口


如何使用Runable类呢?

5d4c6812c8535adbb050f4ddf2e1bce8.png

1dc618a0ed9580ce8bfa6facb208c08f.png

public class Run {
    public static void main(String[] args) {
        MyRunable myRunable = new MyRunable();
        Thread thread = new Thread(myRunable);
        thread.start();
        System.out.println("运行结束");
    }
}

5d4c6812c8535adbb050f4ddf2e1bce8.png

46a9d80a6e05e4e3b19d57a0ee70bcdf.png



3.实例变量与线程安全


5d4c6812c8535adbb050f4ddf2e1bce8.png

(1)不共享数据的情况

1dc618a0ed9580ce8bfa6facb208c08f.png


public class MyThread extends Thread {
    private int count=5;
    public MyThread(String name) {
        super();
        this.setName(name);
    }
    @Override
    public void run() {
        super.run();
        while(count > 0){
            count --;
            System.out.println("由 "  + this.currentThread().getName() + " 计算，count=" + count);
        }
    }
}


public class Run {
    public static void main(String[] args) {
        MyThread a = new MyThread("a");
        MyThread b = new MyThread("b");
        MyThread c = new MyThread("c");
        a.start();
        b.start();
        c.start();
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png

(2)共享数据的情况

1dc618a0ed9580ce8bfa6facb208c08f.png


线程安全问题案例1

测试项目


public class MyThread extends Thread{
    private int count=5;
    @Override
    public void run() {
//        super.run();
//        while(count > 0){
            count --;
            System.out.println("由 "  + this.currentThread().getName() + " 计算，count=" + count);
//        }
    }
}


public class Run {
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        Thread a = new Thread(myThread, "a");
        Thread b = new Thread(myThread,"b");
        Thread c = new Thread(myThread,"c");
        Thread d = new Thread(myThread,"d");
        Thread e = new Thread(myThread,"e");
        a.start();
        b.start();
        c.start();
        d.start();
        e.start();
    }
}


运行结果:

1dc618a0ed9580ce8bfa6facb208c08f.png

结果:每次都不一样。

5d4c6812c8535adbb050f4ddf2e1bce8.png

案例:

46a9d80a6e05e4e3b19d57a0ee70bcdf.png


public class MyThread extends Thread {
    private int count = 5;
    @Override
    synchronized public void run() {
        count--;
        System.out.println("由 " + this.currentThread().getName() + " 计算，count=" + count);
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png

5d4c6812c8535adbb050f4ddf2e1bce8.png


线程安全问题2

public class LoginServlet {
    private static String usernameRef;
    private static String passwordRef;
    public static void doPost(String username, String password){
        try {
            usernameRef = username;
            if(username.equals("a")){
                Thread.sleep(5000);
            }
            passwordRef = password;
            System.out.println("username=" + usernameRef + " password="+passwordRef);
        }catch (InterruptedException e){
           e.printStackTrace();
        }
    }
}


public class Alogin extends  Thread{
    @Override
    public void run() {
        LoginServlet.doPost("a", "aa");
    }
}


public class Blogin extends  Thread {
    @Override
    public void run() {
        LoginServlet.doPost("b", "bb");
    }
}



public class Run {
    public static void main(String[] args) {
        Alogin a = new Alogin();
        a.start();
        Blogin b = new Blogin();
        b.start();
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png

也出现了线程安全问题。


解决方式，也是加上 synchronized


synchronized   public static void doPost(String username, String password){


留意i–和system.out.println()异常

1dc618a0ed9580ce8bfa6facb208c08f.png


案例演示


public class MyThread extends Thread {
    private int i = 5;
    @Override
    public void run() {
        System.out.println("i=" + (i--)+ " threadName=" + Thread.currentThread().getName());
        //注意: 代码i--由前面项目中单独一行运行改成在当前项目中在println()方法中直接进行打印
    }
    public static void main(String[] args) {
        MyThread run = new MyThread();
        Thread t1 = new Thread(run);
        Thread t2 = new Thread(run);
        Thread t3 = new Thread(run);
        Thread t4 = new Thread(run);
        Thread t5 = new Thread(run);
        t1.start();
        t2.start();
        t3.start();
        t4.start();
        t5.start();
    }    
}

1dc618a0ed9580ce8bfa6facb208c08f.png

5d4c6812c8535adbb050f4ddf2e1bce8.png

为了防止发生非线程安全问题，还是应该继续使用同步方法。


4.currentThread()方法


该方法返回代码段正在被哪个线程调用的信息。


1.案例1


public class MyThread extends Thread{
    public MyThread() {
        System.out.println("构造方法的打印: "+ Thread.currentThread().getName());
    }
    @Override
    public void run() {
        System.out.println("run构造方法的打印: "+ Thread.currentThread().getName());
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.start();
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png


改下:


public static void main(String[] args) {
        MyThread myThread = new MyThread();
        myThread.run();
    }


均被main主线程所调用。


2.案例2:


public class CountOperate extends Thread{
    public CountOperate() {
        System.out.println("countOpera---begin");
        System.out.println("Thread.currentThread.getName()=" + Thread.currentThread().getName());
        System.out.println("this.getName()==" + this.getName());
        System.out.println("countOpera---end");
    }
    @Override
    public void run() {
        System.out.println("countOpera---begin");
        System.out.println("Thread.currentThread.getName()=" + Thread.currentThread().getName());
        System.out.println("this.getName()==" + this.getName());
        System.out.println("countOpera---end");
    }
    public static void main(String[] args) {
        CountOperate c = new CountOperate();
        Thread t1  = new Thread(c);
        t1.setName("A");
        t1.start();
    }
}


5.isAlive()方法


判断当前的线程是否是活跃的状态


public class MyThread extends Thread {
    @Override
    public void run() {
        System.out.println("begin==" + this.isAlive());
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        System.out.println("begin==" + myThread.isAlive());
        myThread.start();
        System.out.println("end==" + myThread.isAlive());
    }
}

1dc618a0ed9580ce8bfa6facb208c08f.png

5d4c6812c8535adbb050f4ddf2e1bce8.png

 

public static void main(String[] args) throws InterruptedException {
        MyThread myThread = new MyThread();
        System.out.println("begin==" + myThread.isAlive());
        myThread.start();
        Thread.sleep(1000);
        System.out.println("end==" + myThread.isAlive());
    }


6.sleep()方法



public class MyThread  extends Thread {
    @Override
    public void run() {
        try {
            System.out.println("run threadName="+this.currentThread().getName() + " begin");
            Thread.sleep(2000);
            System.out.println("run threadName="+this.currentThread().getName() + " end");
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        System.out.println("begin = " + System.currentTimeMillis());
        myThread.start();
        System.out.println("end = " + System.currentTimeMillis());
    }
}



修改实验


public static void main(String[] args) {
        MyThread myThread = new MyThread();
        System.out.println("begin = " + System.currentTimeMillis());
        myThread.run();
        System.out.println("end = " + System.currentTimeMillis());
    }


6.getId()方法


public static void main(String[] args) {
        Thread thread = Thread.currentThread();
        System.out.println(thread.getId() + "====" + thread.getName());
    }


当前线程的id为1，名字为main。


文章标签：
Java
安全
关键词：
Java多线程
Java线程
多线程线程
编程线程
线程编程
怒放de生命
目录
相关文章
蓝易云
|
1月前
|
Python
python3多线程中使用线程睡眠
本文详细介绍了Python3多线程编程中使用线程睡眠的基本方法和应用场景。通过 `time.sleep()`函数，可以使线程暂停执行一段指定的时间，从而控制线程的执行节奏。通过实际示例演示了如何在多线程中使用线程睡眠来实现计数器和下载器功能。希望本文能帮助您更好地理解和应用Python多线程编程，提高程序的并发能力和执行效率。
蓝易云
54 20
蓝易云
|
1月前
|
Linux
Linux编程： 在业务线程中注册和处理Linux信号
本文详细介绍了如何在Linux中通过在业务线程中注册和处理信号。我们讨论了信号的基本概念，并通过完整的代码示例展示了在业务线程中注册和处理信号的方法。通过正确地使用信号处理机制，可以提高程序的健壮性和响应能力。希望本文能帮助您更好地理解和应用Linux信号处理，提高开发效率和代码质量。
蓝易云
49 17
蓝易云
|
1月前
|
Linux
Linux编程： 在业务线程中注册和处理Linux信号
通过本文，您可以了解如何在业务线程中注册和处理Linux信号。正确处理信号可以提高程序的健壮性和稳定性。希望这些内容能帮助您更好地理解和应用Linux信号处理机制。
蓝易云
60 26
心疼你的一切
|
1月前
|
安全 Java C#
Unity多线程使用(线程池)
在C#中使用线程池需引用`System.Threading`。创建单个线程时，务必在Unity程序停止前关闭线程（如使用`Thread.Abort()`），否则可能导致崩溃。示例代码展示了如何创建和管理线程，确保在线程中执行任务并在主线程中处理结果。完整代码包括线程池队列、主线程检查及线程安全的操作队列管理，确保多线程操作的稳定性和安全性。
心疼你的一切
35 1
三三是该溜子
|
3月前
|
安全 Java API
【JavaEE】多线程编程引入——认识Thread类
Thread类，Thread中的run方法，在编程中怎么调度多线程
三三是该溜子
71 0
叫个什么名字
|
4月前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区，如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等，并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比，直观展示了正确与错误的实现方式，旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
叫个什么名字
94 5
栈江湖
|
3月前
|
存储 安全 Java
Java多线程编程秘籍：各种方案一网打尽，不要错过！
Java 中实现多线程的方式主要有四种：继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点，适用于不同的场景。继承 Thread 类最简单，实现 Runnable 接口更灵活，Callable 接口支持返回结果，线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外，还介绍了多线程相关的常见面试问题及答案，涵盖线程概念、线程安全、线程池等知识点。
栈江湖
288 2
游客5fdji2pvmf8888
|
4月前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景，并结合代码示例和实用技巧，帮助开发者有效避免这些陷阱，提升并发程序的稳定性和性能。 ####
游客5fdji2pvmf8888
90 16
aliyun0641063962-48771
|
4月前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱，如竞态条件、死锁和内存一致性错误，并提供了实用的避免策略。通过分析典型错误案例，本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧，从而提升并发程序的稳定性和性能。 ####
aliyun0641063962-48771
83 12
潇洒洒
|
3月前
|
缓存 Java 调度
多线程编程核心：上下文切换深度解析
在现代计算机系统中，多线程编程已成为提高程序性能和响应速度的关键技术。然而，多线程编程中一个不可避免的概念就是上下文切换（Context Switching）。本文将深入探讨上下文切换的概念、原因、影响以及优化策略，帮助你在工作和学习中深入理解这一技术干货。
潇洒洒
75 10

热门文章

最新文章

  • 1
    Java也能快速搭建AI应用？一文带你玩转Spring AI可落地性
  • 2
    从理论到实践：使用JAVA实现RAG、Agent、微调等六种常见大模型定制策略
  • 3
    一天成为Java开发高手：用飞算JavaAI实现十倍提效
  • 4
    Java+机器学习基础：打造AI学习基础
  • 5
    深入理解Java锁升级：无锁 → 偏向锁 → 轻量级锁 → 重量级锁（图解+史上最全）
  • 6
    Java实战：使用HttpClient实现图片下载与本地保存
  • 7
    【原理】【Java并发】【volatile】适合初学者体质的volatile原理
  • 8
    课时3：Java简介（Java主要特点）
  • 9
    JVM简介—1.Java内存区域
  • 10
    2K star！三分钟搭建企业级后台系统，这款开源Java框架绝了！
  • 1
    Redis的线程模型
    14
  • 2
    Java网络编程，多线程，IO流综合小项目一一ChatBoxes
    58
  • 3
    【源码】【Java并发】【线程池】邀请您从0-1阅读ThreadPoolExecutor源码
    81
  • 4
    Python实用技巧：轻松驾驭多线程与多进程，加速任务执行
    22
  • 5
    【Java并发】【线程池】带你从0-1入门线程池
    142
  • 6
    【Linux进程概念】—— 操作系统中的“生命体”，计算机里的“多线程”
    50
  • 7
    【YashanDB 知识库】用 yasldr 配置 Bulkload 模式作单线程迁移 300G 的业务数据到分布式数据库，迁移任务频繁出错
    24
  • 8
    Java社招面试题：一个线程运行时发生异常会怎样？
    109
  • 9
    python3多线程中使用线程睡眠
    54
  • 10
    MySQL底层概述—3.InnoDB线程模型
    59

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • 从《阿里巴巴Java开发手册》编写推广谈技术成长
  • 如何通过 Serverless 提高 Java 微服务治理效
  • 多IO线程优化版

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用
  • 部署基于Dragonwell的Java运行环境
    • 下一篇
    获取百炼API-KEY