多线程并发 (二) 了解 Thread

章节:
多线程并发 (一) 了解 Java 虚拟机 - JVM 
多线程并发 (二) 了解 Thread
多线程并发 (三) 锁 synchronized、volatile 
多线程并发 (四) 了解原子类 AtomicXX 属性地址偏移量
多线程并发 (五) ReentrantLock 使用和源码 
多线程并发 (六) 了解死锁
多线程并发 (七) 线程池


通过上一篇 多线程并发 (一) 了解 Java 虚拟机 - JVM 了解了java 虚拟机的构成以及对象的创建等。从Java虚拟机栈我们知道每当我们创建一个线程JVM就会给我们的线程分配一个私有的内存空间和程序计数器记录当前线程运行的次行代码的地址。了解了Thread之后,通过多线程编程进而引入锁(下篇)的概念。

1. 线程简介

线程是进程中可独立执行的最小单位,也是 CPU 资源分配的基本单位

2. 线程的四个属性

    (1)编号Id
              线程的编号(id)用于标识不同的线程,每条线程拥有不同的编号。
    (2) 名字
             每个线程都有自己的名字(name),名字的默认值是 Thread-线程编号,比如 Thread-0 。除了默认值,我们也可以给线程设置名字,以我们自己的方式去区分每一条线程。
    (3)类别
            分为守护线程和用户线程,我们可以通过 setDaemon(true) 把线程设置为守护线程。GC线程是守护线程,对于守护线程JVM退出时不会考虑次线程是否持行完毕。
    (4)优先级
            线程的优先级(Priority)用于表示应用希望优先运行哪个线程,线程调度器会根据这个值来决定优先运行哪个线程。
            Java 中线程优先级的取值范围为 1~10,默认值是 5,Thread 中定义了下面三个优先级常量。
            最低优先级:MIN_PRIORITY = 1
            默认优先级:NORM_PRIORITY = 5
            最高优先级:MAX_PRIORITY = 10

3. 线程的六个方法

线程的常用方法有六个,它们分别是三个非静态方法 start()、run()、join() 和三个静态方法 currentThread()、yield()、sleep() 。我们只关注start()、join()、yield()、sleep(),另外run()、currentThread()容易理解。
(1)yield() 
      顾名思义yield英文 让 的意思。当t.yield() 持行之后 t 回到就绪状态,所有线程重新抢用cpu。
(2)join() 
      t2正在运行,这时在t2线程中调用 t1.join() ,这是让t2 等待线程t1 结束了,再运行。次方法可以让线程按顺序持行。自己线程中调用自己的join方法是无意义的。
(3)sleep()
      暂停阻塞等待一段时间,时间过了就继续。这个方法是不释放锁的。
(4)start()
     启动线程,让cpu调度器调度开启线程持行run()方法。而直接调用run()方法只是运行当前run方法,不会开启线程。

4.线程运行状态

线程调用状态图

分析:1. new 的状态(NEW)
           2. start() 之后线程到达就绪状态等待cpu调度,cpu调度了 就是运行状态。(RUNNABLE)
           3. 调用了 TImedWaiting 就回到就绪状态,结束之后自动到运行状态(TIMED_WAITING)
           4. 调用 Waiting 就绪然后持行相应的方法到运行(WAITING)
           5. 调用 Blocked 等待进入同步代码快的锁。(BLOCKED)
           6. 结束状态Teminated(TERMINATED)
线程被挂起:正在cpu中调度的线程,cpu把该线程丢出去,持行其他线程,这就是线程被挂起。之后又回来持续该线程。(cpu每次只能持行一个线程)

5.Java 线程调度原理

       在任意时刻,CPU 只能执行一条机器指令,每个线程只有获取到 CPU 的使用权后,才可以执行指令。
也就是在任意时刻,只有一个线程占用 CPU,处于运行的状态。
多线程并发运行实际上是指多个线程轮流获取 CPU 使用权,分别执行各自的任务。
线程的调度由 JVM 负责,线程的调度是按照特定的机制为多个线程分配 CPU 的使用权。
线程调度模型分为两类:分时调度模型和抢占式调度模型。

  1. 分时调度模型
    分时调度模型是让所有线程轮流获取 CPU 使用权,并且平均分配每个线程占用 CPU 的时间片。
  2. 抢占式调度模型
    JVM 采用的是抢占式调度模型,根据优先级来选择占用CPU,优先级越高线程被持行的几率就越大,如果线程的优先级都一样,那就随机选择一个线程,并让该线程占用 CPU。
    也就是如果我们同时启动多个线程,并不能保证它们能轮流获取到均等的时间片。
    如果我们的程序想干预线程的调度过程,最简单的办法就是给每个线程设定一个优先级。

6.线程创建的四种方式

    1)继承Thread类创建线程
    2)实现Runnable接口创建线程
    3)使用Callable和Future创建线程
    4)使用线程池例如用Executor框架
具体代码也是非常简单,仅仅贴出Future的代码:

public class MyTask  implements Callable<Object>{    
    private String args1;
    private String args2;
    //构造函数,用来向task中传递任务的参数
    public  MyTask(String args1,String args2) {
        this.args1=args1;
        this.args2=args2;
    }
    //任务执行的动作
    @Override
    public Object call() throws Exception {
        
        for(int i=0;i<100;i++){
            System.out.println(args1+args2+i);
        }
        return true;
    }
}
MyTask myTask = new MyTask("www", "www");
FutureTask<Object> futureTask = new FutureTask<>(myTask);
Thread thread = new Thread(futureTask);
thread.start();
//get()阻塞等待直到任务执行完成。
boolean result = (boolean) futureTask.get();

7.LockSupport

我们可以使用它来阻塞和唤醒线程,功能和wait,notify有些相似,但是LockSupport比起wait,notify功能更强大,也好用的多。
1)对比wait,notify
wait和notify都是Object中的方法,在调用这两个方法前必须先获得锁对象。
当对象的等待队列中有多个线程时,notify只能随机选择一个线程唤醒,无法唤醒指定的线程。
LockSupport的话,我们可以在任何场合使线程阻塞,同时也可以指定要唤醒的线程。

public class LockSupportTest {

    public static void main(String[] args) {
        Thread parkThread = new Thread(new ParkThread());
        parkThread.start();
        System.out.println("开始线程唤醒");
        LockSupport.unpark(parkThread);
        System.out.println("结束线程唤醒");

    }

    static class ParkThread implements Runnable{

        @Override
        public void run() {
            System.out.println("开始线程阻塞");
            LockSupport.park();
            System.out.println("结束线程阻塞");
        }
    }
}

可指定线程阻塞和唤醒。摘学于:https://www.cnblogs.com/takumicx/p/9328459.html

8.CountDownLatch

CountDownLatch开启一组线程,让每个线程去持行自己的任务,等所有线程都持行完毕后,再向下持行代码。比如我们开启一组线程去同步服务器的数据有 播放记录,下载记录,收藏记录等等用户信息。

CountDownLatch latch = new CountDownLatch(5);
        for (int i =0;i<5;i++){
            new Thread(new MyTask(latch,i*1000,i)).start();
        }
        try {
            latch.await();
            Log.e("WXY--","All the tasks are over.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
public class MyTask implements Runnable {
    CountDownLatch latch;
    int delayTime; // Test
    int curThread;
    public MyTask(CountDownLatch latch,int delayTime,int curThread) {
        this.latch = latch;
        this.delayTime = delayTime;
        this.curThread = curThread;
    }
    @Override
    public void run() {
        try {
            Thread.sleep(delayTime);
            Log.e("WXY--","current task = " + curThread);
            latch.countDown();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

这篇相对简单主要是认识线程,了解线程的方法。介绍了两个线程同步的类。下一篇将学习多个线程并发引入的锁等。

由于本人记性不好学者忘着,所以才一字一句的记录下来,若有错误或其他问题请评论区教训我~。

  • 15
    点赞
  • 88
    收藏
    觉得还不错? 一键收藏
  • 打赏
    打赏
  • 19
    评论
### 回答1: Python多线程并发是指在一个进程中同时运行多个线程,以提高程序的执行效率和响应速度。Python中的多线程是基于操作系统的线程实现的,一个Python线程会对应一个操作系统线程。Python提供了多个模块来支持多线程编程,其中最常用的是`threading`模块。 使用`threading`模块创建一个线程非常简单,只需要定义一个函数作为线程的执行体,然后创建一个`Thread`对象并调用它的`start()`方法即可。下面是一个简单的示例代码: ```python import threading def worker(): print('Worker thread is running') t = threading.Thread(target=worker) t.start() ``` 这个程序创建了一个名为`worker`的函数作为线程的执行体,然后创建了一个`Thread`对象`t`,并调用了`t.start()`方法启动线程。当线程启动后,它会自动调用`worker`函数执行线程任务。 除了`Thread`类之外,Python还提供了一些同步原语,如`Lock`、`Event`、`Condition`等,可以用来协调多个线程之间的操作。使用这些同步原语可以避免多个线程同时访问共享资源导致的竞态条件和数据不一致等问题。 在使用多线程时,需要注意线程安全问题。多个线程同时对同一个共享变量进行读写操作时,可能会产生数据不一致、竞态条件等问题。为了避免这些问题,可以使用一些同步机制来保护共享变量的访问,如使用`Lock`来保证同一时刻只有一个线程能够访问共享变量。 ### 回答2: Python多线程并发是指在Python程序中使用多个线程同时执行任务的一种方式。在传统的单线程程序中,任务是顺序执行的,即一个任务执行完毕后,才能执行下一个任务。而在多线程并发中,多个任务可以同时执行,不需要等待前一个任务执行完毕才能执行下一个任务。 Python的多线程并发是通过threading模块来实现的。通过创建多个线程对象,每个线程对象执行一个任务,可以实现多线程并发多线程并发可以提高程序的执行效率,尤其在处理一些耗时任务时,多线程可以同时执行多个任务,节省了等待时间。 然而,Python的多线程并发也存在一些限制。由于Python的全局解释锁(GIL)机制,每个线程在执行时只能使用一个核心,无法充分利用多核处理器的优势。这就意味着,对于计算密集型的任务,多线程并发可能并不能提高速度。但是对于I/O密集型的任务,如文件读写、网络通信等,多线程并发可以显著提高程序的性能。 在编写多线程并发的程序时,需要注意线程之间的同步问题。多个线程可能会同时访问共享的资源,如果没有正确地进行同步,会引发线程安全问题,如数据竞争、死锁等。在Python中,可以使用锁、条件变量等同步工具来解决这些问题。 总之,多线程并发是一种提高程序性能的方法,可以实现多任务同时执行。但要注意线程安全性和GIL的限制,选择合适的情况下使用多线程并发。 ### 回答3: Python的多线程并发是指在同一时间内,程序中多个线程能够同时运行并执行不同的任务。Python提供了多线程的库,如`threading`,可以通过创建多个线程来实现并发执行。 使用多线程并发有以下几个优点: 1. 提高程序的效率:多线程允许多个任务同时执行,可以充分利用多核处理器的计算能力,以提高程序的效率和响应速度。 2. 提高资源利用率:多线程并发可以有效地利用CPU资源,使其不再空闲,避免因为等待IO操作而浪费时间。 3. 改善用户体验:多线程能够将一些耗时的任务放到后台执行,以提供更好的用户体验,如在图形界面应用中,通过多线程进行网络请求,可以避免阻塞主界面。 4. 实现复杂性:多线程并发可以更容易地实现一些复杂的逻辑,如同时处理多个网络请求、同时获取多个数据源等。 但是,Python中的多线程并发有一些需要注意的地方: 1. 全局解释器锁(GIL):由于GIL的存在,Python中的多线程并不能实现真正的并行执行,因为在同一时间只有一个线程可以执行Python字节码。因此,对于需要CPU密集型的任务,多线程并发并不能显著提升性能。 2. 线程安全问题:多线程并发时,多个线程同时访问共享资源可能引发数据竞争和线程安全问题,需要通过锁(Lock)或其他同步机制来解决。 总的来说,Python的多线程并发在处理IO密集型任务、提高用户体验和利用多核处理器等方面具有优势,但对于CPU密集型任务需要考虑全局解释器锁的影响。

“相关推荐”对你有帮助么?

  • 非常没帮助
  • 没帮助
  • 一般
  • 有帮助
  • 非常有帮助
提交
评论 19
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包

打赏作者

WangRain1

你的鼓励将是我创作的最大动力

¥1 ¥2 ¥4 ¥6 ¥10 ¥20
扫码支付:¥1
获取中
扫码支付

您的余额不足,请更换扫码支付或充值

打赏作者

实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值