JAVA多线程笔记

JAVA多线程笔记

线程的基本概念

首先看一下进程和线程之间的区别:

进程:每个进程都有独立的代码和数据空间(进程上下文),进程间的切换会有较大的开销,一个进程包含1--n个线程。(进程是资源分配的最小单位)

线程:同一类线程共享代码和数据空间,每个线程有独立的运行栈和程序计数器(PC),线程切换开销小。(线程是cpu调度的最小单位)

线程的状态
线程和进程一样分为五个阶段:创建、就绪、运行、阻塞、终止。

  1. 新建状态(New):新创建了一个线程对象。
  2. 就绪状态(Runnable):线程对象创建后,其他线程调用了该对象的start()方法。该状态的线程位于可运行线程池中,变得可运行,等待获取CPU的使用权。
  3. 运行状态(Running):就绪状态的线程获取了CPU,执行程序代码。
  4. 阻塞状态(Blocked):阻塞状态是线程因为某种原因放弃CPU使用权,暂时停止运行。直到线程进入就绪状态,才有机会转到运行状态。阻塞的情况分三种:
    (一)、等待阻塞:运行的线程执行wait()方法,JVM会把该线程放入等待池中。(wait会释放持有的锁)
    (二)、同步阻塞:运行的线程在获取对象的同步锁时,若该同步锁被别的线程占用,则JVM会把该线程放入锁池中。
    (三)、其他阻塞:运行的线程执行sleep()或join()方法,或者发出了I/O请求时,JVM会把该线程置为阻塞状态。当sleep()状态超时、join()等待线程终止或者超时、或者I/O处理完毕时,线程重新转入就绪状态。(注意,sleep是不会释放持有的锁)
  5. 结束状态(Dead):线程执行完了或者因异常退出了run()方法,该线程结束生命周期。

Java中多线程的实现

在java中要想实现多线程,有两种手段,一种是继承Thread类,另外一种是实现接口.(Runable接口和Callable接口,并与Future、线程池结合使用)。在Java中,推荐使用线程池方式实现多线程。

继承Thread实现

以下是一个简单的例子

class MyThread extends Thread {    
    @Override    
    public void run() {       
        //TO DO sth.    
    }
}

开启线程,调用线程对象的start方法即可,注意不是调用run方法,调用run方法也行,但是就不是新开线程的方式运行了,而是普通的方法调用。真正是调用start() 方法。

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

实现java.lang.Runnable接口

先说一下java.lang.Runnable吧,它是一个接口,在它里面只声明了一个run()方法:

public interface Runnable {
    public abstract void run();
}

采用Runnable也是非常常见的一种,我们只需要重写run方法即可。下面也来看个实例。

class MyThread implements Runnable {    
    @Override    
    public void run() {       
        //TO DO sth.    
    }
}

在启动的多线程的时候,需要先通过Thread类的构造方法Thread(Runnable target) 构造出对象,然后调用Thread对象的start()方法来运行多线程代码。

public static void main(String[] args) {    
    new Thread(new MyThread()).start();
}

实现java.util.concurrent.Callable接口

Callable位于java.util.concurrent包下,它也是一个接口,在它里面也只声明了一个方法,只不过这个方法叫做call():

public interface Callable<V> {
    /**
     * Computes a result, or throws an exception if unable to do so.
     *
     * @return computed result
     * @throws Exception if unable to compute a result
     */
    V call() throws Exception;
}

那么怎么使用Callable呢?一般情况下是配合ExecutorService来使用的,也可以结合Thread使用。由于需要返回和取消,因此还需要一个参数来传递状态。

Future

Future就是对于具体的Runnable或者Callable任务的执行结果进行取消、查询是否完成、获取结果。必要时可以通过get方法获取执行结果,该方法会阻塞直到任务返回结果。  
Future类位于java.util.concurrent包下,它是一个接口:

public interface Future<V> {
    boolean cancel(boolean mayInterruptIfRunning);
    boolean isCancelled();
    boolean isDone();
    V get() throws InterruptedException, ExecutionException;
    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

因为Future只是一个接口,所以是无法直接用来创建对象使用的,因此就有了下面的FutureTask。

FutureTask

FutureTask实现了RunnableFuture接口,我们先来看一下FutureTask的实现:
public class FutureTask<V> implements RunnableFuture<V>
而RunnableFuture又实现了Runnable, Future接口

public interface RunnableFuture<V> extends Runnable, Future<V> {
    void run();
}

出RunnableFuture继承了Runnable接口和Future接口,而FutureTask实现了RunnableFuture接口。所以它既可以作为Runnable被线程执行,又可以作为Future得到Callable的返回值。
所以实现方式

class MyThread implements Callable {    
    @Override    
    public Object call() throws Exception {         System.out.println(Thread.currentThread().getName());        
    return 1;    
    }
}

调用可以方式1:使用线程池

public void testCallable1() throws ExecutionException, InterruptedException {    
    ExecutorService pool =  Executors.newSingleThreadExecutor();    
    MyThread task = new MyThread();    
    FutureTask<Integer> futureTask = new FutureTask<Integer>(task);
    pool.submit(futureTask);    
    System.out.println(futureTask.get());
}

调用方式2:使用线程对象

 MyThread task = new MyThread();   
 FutureTask<Integer> futureTask = new FutureTask<Integer>(task);
 Thread thread = new Thread(futureTask).start();
 System.out.println(futureTask.get());

实现线程方式的比较

实现Runnable接口比继承Thread类所具有的优势:

1):适合多个相同的程序代码的线程去处理同一个资源

2):可以避免java中的单继承的限制

3):增加程序的健壮性,代码可以被多个线程共享,代码和数据独立

4):线程池只能放入实现Runable或callable类线程,不能直接放入继承Thread的类

线程同步

synchronized关键字

synchronized关键字的作用域有三种:

1)在实例方法前面加上synchronized关键字,synchronized aMethod(){}可以防止多个线程同时访问这个对象的synchronized方法。

2)在类方法前面加上synchronized关键字,synchronized static bMethod(){}可以防止多个线程同时访问这个synchronized方法。

3)synchronized关键字还可以用于方法中的某个区块中,表示只对这个区块的资源实行互斥访问。

值得注意的是,synchronized关键字是不能继承的,也就是说,基类的方法synchronized f(){} 在继承类中并不自动是synchronized f(){},而是变成了f(){}。继承类需要你显式的指定它的某个方法为synchronized方法。

并发包的lock工具

在JavaSE5.0中新增了一个java.util.concurrent包来支持同步。

ReentrantLock

ReentrantLock类是可重入、互斥、实现了Lock接口的锁, 它与使用synchronized方法和快具有相同的基本行为和语义,并且扩展了其能力
    ReenreantLock类的常用方法有:       
ReentrantLock() : 创建一个ReentrantLock实例 
    lock() : 获得锁 
    unlock() : 释放锁 

一个简单的demo
ReentrantLock lock = new ReentrantLock();
lock.lock();
int syncNum = 1;
try {    
     syncNum++ ;
} finally {    
     lock.unlock();
}

注:ReentrantLock()还有一个可以创建公平锁的构造方法,但由于会大幅度降低程序运行效率,不推荐使用 。

其他的一些方法实现同步

(1)原子变量实现线程同步
在java的util.concurrent.atomic包中提供了创建了原子类型变量的工具类,使用该类可以简化线程同步。
(2)使用volatile关键字
(3)使用ThreadLocal避免并发问题
(4)util.concurrent下实现了很多线程安全的集合类,可以使用

同步可能产生的问题

线程僵死

如果一个线程等待一个永远不会释放的锁,那么线程就会一直无法运行。

死锁

只要您拥有多个进程或者线程,而且它们要争用对多个锁的独占访问,那么就有可能发生死锁。如果有一组进程或线程,其中每个都在等待一个只有其它进程或线程才可以执行的操作,那么就称它们被死锁了。

性能问题

同步由于需要获得锁才能运行,如果多个线程竞争,那么就会导致性能下降。但是需要保证线程同步的正确性,再进行锁的优化。

线程相关的方法

  1. sleep(long millis): 在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)

  2. join():指等待t线程终止。
            join是Thread类的一个方法,启动线程后直接调用,即join()的作用是:“等待该线程终止”,这里需要理解的就是该线程是指的主线程等待子线程的终止。也就是在子线程调用了join()方法后面的代码,只有等到子线程结束了才能执行。

  3. yield():暂停当前正在执行的线程对象,并执行其他线程。
            Thread.yield()方法作用是:暂停当前正在执行的线程对象,并执行其他线程。
             yield()应该做的是让当前运行线程回到可运行状态,以允许具有相同优先级的其他线程获得运行机会。因此,使用yield()的目的是让相同优先级的线程之间能适当的轮转执行。但是,实际中无法保证yield()达到让步目的,因为让步的线程还有可能被线程调度程序再次选中。

  4. setPriority(): 更改线程的优先级。
    线程优先级最大是10,最小是1,默认是5。
    MIN_PRIORITY = 1       
    NORM_PRIORITY = 5         
    MAX_PRIORITY = 10

  5. interrupt():让出入阻塞的线程抛出一个中断信号
    不要以为它是中断某个线程!它只是线线程发送一个中断信号,让线程在无限等待时(如死锁时)能抛出,从而结束线程,但是如果你try了这个异常,那么这个线程还是不会中断的!
    注意如果线程没有阻塞,那么是不会抛出InterruptedException的。

  6. setDaemon():指明某个线程是守护程序线程
    守护程序线程作为在程序中创建的后台线程,如果程序中所有的非守护线程执行完成,那么程序就会推出。例如垃圾回收的线程等也是后台线程。

  7. Obj.wait(),与Obj.notify()
    Obj.wait(),与Obj.notify()必须要与synchronized(Obj)一起使用,也就是wait,与notify是针对已经获取了Obj锁进行操作。
    从语法角度来说就是Obj.wait(),Obj.notify必须在synchronized(Obj){...}语句块内。从功能上来说wait就是说线程在获取对象锁后,主动释放对象锁,同时本线程休眠。直到有其它线程调用对象的notify()唤醒该线程,才能继续获取对象锁,并继续执行。

wait和sleep区别

共同点:

  1. 他们都是在多线程的环境下,都可以在程序的调用处阻塞指定的毫秒数,并返回。
  2. wait()和sleep()都可以通过interrupt()方法 打断线程的暂停状态 ,从而使线程立刻抛出InterruptedException。
       如果线程A希望立即结束线程B,则可以对线程B对应的Thread实例调用interrupt方法。如果此刻线程B正在wait/sleep /join,则线程B会立刻抛出InterruptedException,在catch() {} 中直接return即可安全地结束线程。
       需要注意的是,InterruptedException是线程自己从内部抛出的,并不是interrupt()方法抛出的。对某一线程调用 interrupt()时,如果该线程正在执行普通的代码,那么该线程根本就不会抛出InterruptedException。但是,一旦该线程进入到 wait()/sleep()/join()后,就会立刻抛出InterruptedException 。

不同点:

  1. Thread类的方法:sleep(),yield()等
       Object的方法:wait()和notify()等
  2. 每个对象都有一个锁来控制同步访问。Synchronized关键字可以和对象的锁交互,来实现线程的同步。
       sleep方法没有释放锁,而wait方法释放了锁,使得其他线程可以使用同步控制块或者方法。
  3. wait,notify和notifyAll只能在同步控制方法或者同步控制块里面使用,而sleep可以在任何地方使用

ref.

https://blog.csdn.net/evankaka/article/details/44153709

 
 
 
 
 
欢迎关注我公众号:

发表回复

您的电子邮箱地址不会被公开。

粤ICP备17041560号-2