多线程

六月 26, 2018 本文总阅读量次

1.线程创建有两种方法

（1）：继承thread方法

（2）：实现runnable接口

2.线程具有五钟状态

新建状态（new）——>就绪状态（runnable）——>运行状态（running）——>阻塞状态（blocked）——>死亡状态（Dead）

3.线程安全

public class ThreadTest {

public static void main(String[] args) {
    Account account = new Account("123456", 1000);
    DrawMoneyRunnable drawMoneyRunnable = new DrawMoneyRunnable(account, 700);
    Thread myThread1 = new Thread(drawMoneyRunnable);
    Thread myThread2 = new Thread(drawMoneyRunnable);
    myThread1.start();
    myThread2.start();
}

}

class DrawMoneyRunnable implements Runnable {

private Account account;
private double drawAmount;

public DrawMoneyRunnable(Account account, double drawAmount) {
    super();
    this.account = account;
    this.drawAmount = drawAmount;
}

public synchronized  void run() {
    if (account.getBalance() >= drawAmount) {  //1
        System.out.println("取钱成功， 取出钱数为：" + drawAmount);
        double balance = account.getBalance() - drawAmount;
        account.setBalance(balance);
        System.out.println("余额为：" + balance);
    }
}

}

class Account {

private String accountNo;
private double balance;

public Account() {

}

public Account(String accountNo, double balance) {
    this.accountNo = accountNo;
    this.balance = balance;
}

public String getAccountNo() {
    return accountNo;
}

public void setAccountNo(String accountNo) {
    this.accountNo = accountNo;
}

public double getBalance() {
    return balance;
}

public void setBalance(double balance) {
    this.balance = balance;
}

}
上面例子很容易理解，有一张银行卡，里面有1000的余额，程序模拟你和你老婆同时在取款机进行取钱操作的场景。多次运行此程序，可能具有多个不同组合的输出结果。其中一种可能的输出为：

取钱成功，取出钱数为：700.0
余额为：300.0
取钱成功，取出钱数为：700.0
余额为：-400.0
也就是说，对于一张只有1000余额的银行卡，你们一共可以取出1400，这显然是有问题的。

经过分析，问题在于Java多线程环境下的执行的不确定性。CPU可能随机的在多个处于就绪状态中的线程中进行切换，因此，很有可能出现如下情况：当thread1执行到//1处代码时，判断条件为true，此时CPU切换到thread2，执行//1处代码，发现依然为真，然后执行完thread2，接着切换到thread1，接着执行完毕。此时，就会出现上述结果。

因此，讲到线程安全问题，其实是指多线程环境下对共享资源的访问可能会引起此共享资源的不一致性。因此，为避免线程安全问题，应该避免多线程环境下对此共享资源的并发访问。

二.同步方法

对共享资源进行访问的方法定义中加上synchronized关键字修饰，使得此方法称为同步方法。可以简单理解成对此方法进行了加锁，其锁对象为当前方法所在的对象自身。多线程环境下，当执行此方法时，首先都要获得此同步锁（且同时最多只有一个线程能够获得），只有当线程执行完此同步方法后，才会释放锁对象，其他的线程才有可能获取此同步锁，以此类推…

在上例中，共享资源为account对象，当使用同步方法时，可以解决线程安全问题。只需在run()方法前加上synshronized关键字即可。

public synchronized void run() {

// ....

}

三.同步代码块

正如上面所分析的那样，解决线程安全问题其实只需限制对共享资源访问的不确定性即可。使用同步方法时，使得整个方法体都成为了同步执行状态，会使得可能出现同步范围过大的情况，于是，针对需要同步的代码可以直接另一种同步方式——同步代码块来解决。

同步代码块的格式为：

synchronized (obj) {

//...

}
使用同步方法和同步快可以避免线程安全

四.Lock对象同步锁

 // 显示定义Lock同步锁对象，此对象与共享资源具有一对一关系
private final Lock lock = new ReentrantLock();

public   void run() {
     lock.lock();
    if (account.getBalance() >= drawAmount) {  //1
        System.out.println("取钱成功， 取出钱数为：" + drawAmount);
        double balance = account.getBalance() - drawAmount;
        account.setBalance(balance);
        System.out.println("余额为：" + balance);
    }
 // 释放Lock锁
  lock.unlock();
}

五.wait()/notify()/notifyAll()线程通信

wait()：导致当前线程等待并使其进入到等待阻塞状态。直到其他线程调用该同步锁对象的notify()或notifyAll()方法来唤醒此线程。

notify()：唤醒在此同步锁对象上等待的单个线程，如果有多个线程都在此同步锁对象上等待，则会任意选择其中某个线程进行唤醒操作，只有当前线程放弃对同步锁对象的锁定，才可能执行被唤醒的线程。

notifyAll()：唤醒在此同步锁对象上等待的所有线程，只有当前线程放弃对同步锁对象的锁定，才可能执行被唤醒的线程。

package com.qqyumidi;

public class ThreadTest {

public static void main(String[] args) {
    Account account = new Account("123456", 0);

    Thread drawMoneyThread = new DrawMoneyThread("取钱线程", account, 700);
    Thread depositeMoneyThread = new DepositeMoneyThread("存钱线程", account, 700);

    drawMoneyThread.start();
    depositeMoneyThread.start();
}

}

class DrawMoneyThread extends Thread {

private Account account;
private double amount;

public DrawMoneyThread(String threadName, Account account, double amount) {
    super(threadName);
    this.account = account;
    this.amount = amount;
}

public void run() {
    for (int i = 0; i < 100; i++) {
        account.draw(amount, i);
    }
}

}

class DepositeMoneyThread extends Thread {

private Account account;
private double amount;

public DepositeMoneyThread(String threadName, Account account, double amount) {
    super(threadName);
    this.account = account;
    this.amount = amount;
}

public void run() {
    for (int i = 0; i < 100; i++) {
        account.deposite(amount, i);
    }
}

}

class Account {

private String accountNo;
private double balance;
// 标识账户中是否已有存款
private boolean flag = false;

public Account() {

}

public Account(String accountNo, double balance) {
    this.accountNo = accountNo;
    this.balance = balance;
}

public String getAccountNo() {
    return accountNo;
}

public void setAccountNo(String accountNo) {
    this.accountNo = accountNo;
}

public double getBalance() {
    return balance;
}

public void setBalance(double balance) {
    this.balance = balance;
}

/**
 * 存钱
 *
 * @param depositeAmount
 */
public synchronized void deposite(double depositeAmount, int i) {

    if (flag) {
        // 账户中已有人存钱进去，此时当前线程需要等待阻塞
        try {
            System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " -- i=" + i);
            wait();
            // 1
            System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " -- i=" + i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    } else {
        // 开始存钱
        System.out.println(Thread.currentThread().getName() + " 存款:" + depositeAmount + " -- i=" + i);
        setBalance(balance + depositeAmount);
        flag = true;

        // 唤醒其他线程
        notifyAll();

        // 2
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "-- 存钱 -- 执行完毕" + " -- i=" + i);
    }
}

/**
 * 取钱
 *
 * @param drawAmount
 */
public synchronized void draw(double drawAmount, int i) {
    if (!flag) {
        // 账户中还没人存钱进去，此时当前线程需要等待阻塞
        try {
            System.out.println(Thread.currentThread().getName() + " 开始要执行wait操作" + " 执行了wait操作" + " -- i=" + i);
            wait();
            System.out.println(Thread.currentThread().getName() + " 执行了wait操作" + " 执行了wait操作" + " -- i=" + i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    } else {
        // 开始取钱
        System.out.println(Thread.currentThread().getName() + " 取钱：" + drawAmount + " -- i=" + i);
        setBalance(getBalance() - drawAmount);

        flag = false;

        // 唤醒其他线程
        notifyAll();

        System.out.println(Thread.currentThread().getName() + "-- 取钱 -- 执行完毕" + " -- i=" + i); // 3
    }
}

}
由此，我们需要注意如下几点：

1.wait()方法执行后，当前线程立即进入到等待阻塞状态，其后面的代码不会执行；

2.notify()/notifyAll()方法执行后，将唤醒此同步锁对象上的（任意一个-notify()/所有-notifyAll()）线程对象，但是，此时还并没有释放同步锁对象，也就是说，如果notify()/notifyAll()后面还有代码，还会继续进行，知道当前线程执行完毕才会释放同步锁对象；

3.notify()/notifyAll()执行后，如果右面有sleep()方法，则会使当前线程进入到阻塞状态，但是同步对象锁没有释放，依然自己保留，那么一定时候后还是会继续执行此线程，接下来同2；

4.wait()/notify()/nitifyAll()完成线程间的通信或协作都是基于不同对象锁的，因此，如果是不同的同步对象锁将失去意义，同时，同步对象锁最好是与共享资源对象保持一一对应关系；

5.当wait线程唤醒后并执行时，是接着上次执行到的wait()方法代码后面继续往下执行的。

当然，上面的例子相对来说比较简单，只是为了简单示例wait()/notify()/noitifyAll()方法的用法，但其本质上说，已经是一个简单的生产者-消费者模式了。

查看评论