Java多线程
整理转载自:
https://www.cnblogs.com/wxd0108/p/5479442.html
http://www.runoob.com/java/java-multithreading.html
目录
二、 继承Thread类和实现Runnable实现多线程 2
2. 如何使用synchronized同步解决多线程共享数据同步问题 12
3. 讨论synchronized用到不同地方对代码产生的影响: 12
5. synchronized, wait, notify结合:典型场景生产者消费者问题 14
首先我们先了解下在操作系统中进程和线程的区别:
Java想要实现多线程,有两种方法,一种是继承Thread类,另一种是实现Runnable接口。
class Thread1 extends Thread{ public Thread1(){ //重写类的构造方法 } public void run(){ //重写父类run方法 } } public class Main {
public static void main(String[] args) { Thread1 mTh1=new Thread1("A"); Thread1 mTh2=new Thread1("B"); mTh1.start(); mTh2.start();
}
} |
输出: A运行 : 0 B运行 : 0 A运行 : 1 A运行 : 2 A运行 : 3 A运行 : 4 B运行 : 1 B运行 : 2 B运行 : 3 B运行 : 4 再运行一下: A运行 : 0 B运行 : 0 B运行 : 1 B运行 : 2 B运行 : 3 B运行 : 4 A运行 : 1 A运行 : 2 A运行 : 3 A运行 : 4 |
程序启动运行main()的时候,Java虚拟机会启动一个进程,主线程main在main(0函数调用时候被创建,随着调用Main类的两个对象的start()方法,另外两个线程也被启动,这样,整个应用程序就在多线程下运行。
线程对象只会调用start()方法,不会调用run()方法,run()方法的执行是由操作系统决定的。
注意:start()方法调用后并不是立即执行多线程代码,而是使得该线程变为可运行态(Runnable),什么时候运行是由操作系统决定的。
从程序运行的结果可以发现,多线程程序是乱序执行的,只有乱序执行的代码才有必要设计为多线程。
Thread.sleep()方法调用的目的是不让当前线程独自霸占该进程所获取的CPU资源,以留出一定时间给其他线程执行的机会。
实际上,所有的多线程代码的执行顺序都是不确定的,每次执行的结果都是随机的。
但是start方法重复调用的话,会出现java.lang.IllegalThreadStateException异常。
采用实现Runnable接口也是创建多线程的一种方法
class Thread2 implements Runnable{ private String name;
public Thread2(String name) { this.name=name; }
@Override public void run() { for (int i = 0; i < 5; i++) { System.out.println(name + "运行 : " + i); try { Thread.sleep((int) Math.random() * 10); } catch (InterruptedException e) { e.printStackTrace(); } }
}
} public class Main {
public static void main(String[] args) { new Thread(new Thread2("C")).start(); new Thread(new Thread2("D")).start(); }
} |
输出:
C运行 : 0 D运行 : 0 D运行 : 1 C运行 : 1 D运行 : 2 C运行 : 2 D运行 : 3 C运行 : 3 D运行 : 4 C运行 : 4 |
Thread2类通过实现Runnable接口,使得该类有了多线程类的特征。run()方法是多线程程序的一个约定。所有的多线程代码都在run方法里面。Thread类实际上也是实现了Runnable接口的类。
在启动的多线程的时候,需要先通过Thread类的构造方法Thread(Runnable target) 构造出对象,然后调用Thread对象的start()方法来运行多线程代码。
实际上所有的多线程代码都是通过运行Thread的start()方法来运行的。因此,不管是扩展Thread类还是实现Runnable接口来实现多线程,最终还是通过Thread的对象的API来控制线程的,熟悉Thread类的API是进行多线程编程的基础。
如果一个类继承Thread,则不适合资源共享。但是如果实现了Runable接口的话,则很容易的实现资源共享。
总结:
实现Runnable接口比继承Thread类所具有的优势:
1):适合多个相同的程序代码的线程去处理同一个资源
2):可以避免java中的单继承的限制
3):增加程序的健壮性,代码可以被多个线程共享,代码和数据独立
4):线程池只能放入实现Runable或callable类线程,不能直接放入继承Thread的类
提醒一下大家:main方法其实也是一个线程。在java中所以的线程都是同时启动的,至于什么时候,哪个先执行,完全看谁先得到CPU的资源。
在java中,每次程序运行至少启动2个线程。一个是main线程,一个是垃圾收集线程。因为每当使用java命令执行一个类的时候,实际上都会启动一个JVM,每一个jVM实习在就是在操作系统中启动了一个进程。
使用new关键字和Thread类或其子类建立一个线程对象后,该线程对象就处于新建状态。它保持这个状态直到程序start()这个线程。
当线程调用了start()方法之后,该线程就进入就绪状态。就绪状态的线程处于就绪队列中,要等待JVM里线程调度器的调度。
如果就绪状态的线程获取CPU资源,就可以执行run(),此时线程便处于运行状态。处于运行状态的线程最为复杂,它可以变为阻塞状态、就绪状态和死亡状态。
如果一个线程执行了sleep()休眠、suspend()挂起等方法,失去所占用资源之后,该线程就从运行状态进入阻塞状态。在睡眠时间已到或获得设备资源后可以重新进入就绪状态。可以分为以下三种:
Sleep()不会释放持有的锁,只会超时使得线程终止。
每一个 Java 线程都有一个优先级,这样有助于操作系统确定线程的调度顺序。Java 线程的优先级是一个整数,其取值范围是 1 (Thread.MIN_PRIORITY ) - 10 (Thread.MAX_PRIORITY )。
线程可以具有的最高优先级,取值为10。
线程可以具有的最低优先级,取值为1。
默认情况下,每一个线程都会分配一个优先级 NORM_PRIORITY(5)。
具有较高优先级的线程对程序更重要,并且应该在低优先级的线程之前分配处理器资源。但是,线程优先级不能保证线程执行的顺序,而且非常依赖于平台。
Thread.sleep(long millis)方法,使线程转到阻塞状态。millis参数设定睡眠的时间,以毫秒为单位。当睡眠结束后,就转为就绪(Runnable)状态
线程等待:Object类中的wait()方法,导致当前的线程等待,直到其他线程调用此对象的 notify() 方法或 notifyAll() 唤醒方法。
线程让步:Thread.yield() 方法,暂停当前正在执行的线程对象,把执行机会让给相同或者更高优先级的线程。
线程加入:join()方法,等待其他线程终止。在当前线程中调用另一个线程的join()方法,则当前线程转入阻塞状态,直到另一个进程运行结束,当前线程再由阻塞转为就绪状态。
在指定的毫秒数内让当前正在执行的线程休眠(暂停运行)
指等待t线程终止。该线程是指的主线程等待子线程的终止。有时主线程需要等待子线程执行完成之后再结束,这个时候就要用到join()方法了。
暂停当前正在执行的线程对象,并执行其他线程。
yield()应该做的是让当前运行线程回到可运行状态,以允许具有相同优先级的其他线程获得运行机会。
yield()不会导致线程转到等待/睡眠/阻塞状态
在进一步阐述之前,我们需要明确几点:
A.无论synchronized关键字加在方法上还是对象上,它取得的锁都是对象,而不是把一段代码或函数当作锁――而且同步方法很可能还会被其他线程的对象访问。
B.每个对象只有一个锁(lock)与之相关联。
C.实现同步是要很大的系统开销作为代价的,甚至可能造成死锁,所以尽量避免无谓的同步控制。
Public synchronized void methodAAA() { //…. } |
这也就是同步方法,那这时synchronized锁定的是哪个对象呢?它锁定的是调用这个同步方法对象。也就是说,当一个对象P1在不同的线程中执行这个同步方法时,它们之间会形成互斥,达到同步的效果。但是这个对象所属的Class所产生的另一对象P2却可以任意调用这个被加了synchronized关键字的方法。
public void method3(SomeObject so){ synchronized(so){ //….. } } |
这时,锁就是so这个对象,谁拿到这个锁谁就可以运行它所控制的那段代码。当有一个明确的对象作为锁时,就可以这样写程序。
Class Foo { public synchronized static void methodAAA() { //…. } public void methodBBB() { synchronized(Foo.class) // class literal(类名称字面常量) } } |
代码中的methodBBB()方法是把class literal作为锁的情况,它和同步的static函数产生的效果是一样的,取得的锁很特别,是当前调用这个方法的对象所属的类(Class,而不再是由这个Class产生的某个具体对象了)。
public synchronized void consume() { if(this.product <= MIN_PRODUCT) { try { wait(); System.out.println("缺货,稍候再取"); } catch (InterruptedException e) { e.printStackTrace(); } return; } System.out.println("消费者取走了第" + this.product + "个产品."); this.product--; notifyAll(); //通知等待去的生产者可以生产产品了 } |
main memory(主存)、working memory(线程栈),在处理数据时,线程会把值从主存load到本地栈,完成操作后再save回去(volatile关键词的作用:每次针对该变量的操作都激发一次load and save)。
原文:https://www.cnblogs.com/yejintianming00/p/9522174.html