在现代的操作系统中，有一个很重要的概念
1，什么是发布订阅模式？ 在软件架构中，发布订阅是一种消息范式，消息的发送者（称为发布者）不会将消息直接发送给特定的接收者（称为订阅者）。而是将发布的消息分为不同的类别，无需了解哪些订阅者（如果有的话）可能存在。同样的，订阅者可以表达对一个或多个类别的兴趣，只接收感兴趣的消息，无需了解哪些发布者（如果有的话）存在。 Java9开始新增了一个发布-订阅框架，框架是基于异步响应流。发布，订阅框架可以非常方便地处...
线程安全概念：当多个线程访问某一个类（对象或方法）时，这个对象始终都能表现出正确的行为，那么这个类（对象或方法）就是线程安全的。分析：当多个线程访问myThread的run方法时，以排队的方式进行处理（这里排对是按照CPU分配的先后顺序而定的），一个线程想要执行synchronized修饰的方法里的代码：1 尝试获得锁 2 如果拿到锁，执行synchronized代码体内容；拿不到锁，这个线程就会不断的尝试获得这把锁，直到拿到为止，而且...
Java线程的声明周期这篇博客介绍线程的生命周期。 线程是一个动态执行的过程，它也有从创建到死亡的过程。在 Thread 类中，有一个枚举内部类： 上面的信息以图片表示如下： 第一张图： 第二张图：把等待、计时等待、阻塞看成阻塞一个状态了 1、新建状态（new）:使用 new 创建一个线程，仅仅只是在堆中分配了内存空间 新建状态下，线程还没有调用 start()方法启动，只是存在一个线程对象...
问题：ArrayList 等线程不安全 当多线程并发修改一个集合数据时，可能同一个下标位置被覆盖。 示例代码： 一个List，我们创建10个线程，每个线程往这个List中添加1000条数据,结果往往不是预期的10000个大小：import java.util.ArrayList; import java.util.List; import java.util.Random; import java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveAction; import java.util.concurrent.TimeUnit;/*** @...
新增方式一：实现Callable接口与使用Runnable相比， Callable功能更强大些 ? 相比run()方法，可以有返回值 ? 方法可以抛出异常 ? 支持泛型的返回值 ? 需要借助FutureTask类，比如获取返回结果? Future接口 ? 可以对具体Runnable、Callable任务的执行结果进行取消、查询是 否完成、获取结果等。 ? FutrueTask是Futrue接口的唯一的实现类 ? FutureTask 同时实现了Runnable, Future接口。它既可以作为 Runnable被线程执行，又可以作为...
学习狂神视频的第六天 文章目录 前言：一、抢火车票结果 二、银行取钱结果 三、用链表直观的表示线程的不安全Java进阶之多线程：线程是不安全的（三大样例）前言： 前面我们一直在说，线程是不安全的，本节课狂神介绍了三个样例，来证明了线程是不安全的。 一、抢火车票 import jdk.swing.interop.SwingInterOpUtils;// 不安全的买票 // 线程不安全，有负数 public class UnsafeBuyTicket {public static void main(String[] args)...
Java多线程常用方法 方法一：Thread类的静态方法sleep() 作用：让当前线程停止执行，把CPU让给其他线程执行，但不会释放对象锁和监控的状态，也就是如果有Synchronized同步块，其他线程仍然不同访问共享数据。到了指定时间后线程又会自动恢复运行状态。 线程状态变化：运行 --》 等待 。 sleep时间到后线程自动由 等待 --》 就绪 注意：线程睡眠到期自动苏醒，并返回到可运行状态，不是运行状态。sleep()中指定的时间是线程不会运行...
目录1. 基本概念2. 线程的创建和启动2.1. 多线程实现的原理2.2.多线程的创建，方式一：继承于Thread类2.3.多线程的创建，方式一：创建Thread匿名子类（也属于方法一）2.4. 多线程的创建，方式二：实现Runnable接口2.4.1. 比较创建线程的两种方式2.5. 多线程的创建，方式三：实现Callable接口2.6. 多线程的创建，方式四：线程池3. Thread类的常用方法4. 线程的调度4.1. cpu的调度策略4.2. Java的调度算法：5. 线程的生命周期6. 线程...
最近学习了一下极客时间的《Java 并发编程实战》对Java的线程池有了新的认识并且有了自己的理解，以及一些设想，例如能否设计一个分布式的线程池，能否设计一个可以动态修改参数的线程池，能否设计一个可以实时监控任务执行情况的线程池，因此发表这篇帖子，希望与大家一起进步，一起天马星空。 首先：我想说一下自己接触编程5年对线程池的理解心路历程，初学代码一年搞懂C语言的计算器（Computer）,入行两年接触面向对象的编程思想...
interrupt() 方法 ? 其作用是中断此线程（此线程不一定是当前线程，而是指调用该方法的Thread实例所代表的线程），但实际上只是给线程设置一个中断标志，线程仍会继续运行。 实例： 先输出10次线程名，然后等待20秒，在主方法调用interrupt()方法。 class ThreadTest extends Thread {@Overridepublic void run() {while (true) {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + " " + i)...
ReentrantReadWriteLock： 类ReentrantLock具有相互互斥的排他效果，也就是说，同一时间，只有一个线程执行lock()方法后面的任务。这样做虽然可以解决问题，但是效率非常低。使用ReentrantReadWriterLock可以加快运行效率，某些不需要操作实例变量的方法中，完全可以使用它来提升代码运行效率。 为什么不需要操作实例变量变量方法才可以用它来提升效率呢？(1),读读不互斥 (2),读写互斥 (3),写读互斥 (4),写写互斥读读不互斥：impor...
ReentrantLock 常用方法getHoldCount获取当前线程被锁定的次数，如果调用unlock，锁定次数会减去1： lock.getQueueLength() 等待获取该锁的线程的个数 lock.getWaitQueueLength(condition) 获取某个lock下的所有condition被调用await的个数，也就是暂停状态等待被唤醒的线程个数。 lock.hasQueuedThread(t2) 判断某个线程是否正在等待该锁 lock.hasWaiters(condition) 判断是否有线程用了本锁下面的Condition await等待中 isFair(...
java 中创建线程有哪几种方式 一：继承Thread类创建线程类 定义Thread的子类。重写该子类的run()方法。创建该子类的实例对象，即创建了线程对象。调用线程对象的start()方法来启动线程。 二、通过Runnable接口创建线程类 定义runnable接口的实现类，并重写该接口的run()方法创建 Runnable实现类的实例，并依此实例作为Thread的target来创建Thread对象，该Thread对象才是真正的线程对象。调用线程对象的start()方法来启动该线程。 三...
摘要：多线程可以理解为在同一个程序中能够同时运行多个不同的线程来执行不同的任务，这些线程可以同时利用CPU的多个核心运行。 多线程可以理解为在同一个程序中能够同时运行多个不同的线程来执行不同的任务，这些线程可以同时利用CPU的多个核心运行。多线程编程能够最大限度的利用CPU的资源。本文将通过以下几个方向为大家讲解多线程的用法。1.Thread类基础 2.synchronized关键字 3.其他的同步工具CountDownLatch FutureTask Sema...