二、准备知识
在分析这个例子之前,然我们先看看关于线程的几个概念,上锁,信号量,和java所提供的API。
上锁
对于大多数的程序而言,他们都需要线程之间相互的通讯来完成整个线程的生命周期,二实现线程之间同步的最简单的办法就是上锁。为了防止相互关联的两个线程之间错误地访问共享资源,线程需要在访问资源的时候上锁和解锁,对于锁而言,有读锁,写锁和读写锁等不同的同步策略。在java中,所有的对象都有锁;线程只需要使用synchronized关键字就可以获得锁。在任一时刻对于给定的类的实例,方法或同步的代码块只能被一个线程执行。这是因为代码在执行之前要求获得对象的锁。
信号量
通常情况下,多个线程所访问为数不多的资源,那怎么控制呢?一个比较非常经典而起非常简单的办法就是采用信号量机制。信号量机制的含义就是定义一个信号量,也就是说能够提供的连接数;当有一个线程占用了一个连接时,信号量就减一;当一个线程是放了连接时,信号量就加一。采用这种方法就可以简单有效地控制线程的同步问题,而且实现起来也特别方便。看下面的代码:
class Semaphore {
private int count;
public Semaphore(int count) {
this.count = count;
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)public synchronized void acquire() {
while(count == 0) {
try {
wait();
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)} catch (InterruptedException e) {
//keep trying
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)count--;
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)public synchronized void release() {
count++;
notify(); //alert a thread that′s blocking on this semaphore
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)}
java中提供了哪些api以编写多线程程序
这里只列出几个常用的方法和属性值。
属性值,有三个MAX_PRIORITY,MIN_PRIORITY,NORM_PRIORITY
方法:
Thread(); //建立一个线程
void run(); //对于一个继承了Runnable接口的class而言,
//他运行一个线程,否着他什么都不做
void setPriority(int newPriority); //设置优先级
void start(); //运行一个程序
void sleep(long millis); //线程睡眠millis毫秒
static void yield(); //临时pause一个程序以便起他线程运行
例一、
让我们看看下面的例子。取钱的流程是输入密码,然后确定要取得金额,如果所取的金额小于或等于可以取出的金额,WITHDRAW则返回TRUE,然后ATM机出钱,然后打印清单;否则返回FALSE,然后打印清单。如下图:
public class AutomatedTellerMachine extends Teller {
public void withdraw(float amount) {
Account a = getAccount();
if (a.deduct(amount))
dispense(amount);
printReceipt();
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)public class Account {
private float total;
public boolean deduct(float t) {
if (t = total) {
total -= t;
return true;
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)return false;
}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)}
(本文来源于图老师网站,更多请访问http://m.tulaoshi.com/bianchengyuyan/)就这个例子而言,假设有这种情况,对同一个账号可以在不同的地方取钱,在同一时间,不同地点,妻子和丈夫取钱,妻子输入了账号上的最大金额,丈夫也是一样,假如妻子输入后已经得到true的返回值,但是丈夫的线程所得到的值还没有更新,这样丈夫也能够得到true的返回值,这样就出现了问题!这个问题怎么解决呢?在java里面提供了控制机制以保证deduct操作时的原子性,那就是关键字synchronized。
在Account的deduct方法加入synchronized就可以解决这个问题。
例二、
在这里我们用多线程中最典型的例子,生产者与消费者问题。在这个例子里面我们定义了生产者Producer,消费者Consumer和仓库Warehouse三个类,在整个程序的生命周期里,生产者随机地制造出产品放到仓库中,消费者也是随即地从仓库中取出产品。
import exception.ProducerConsumerException;
/**
* Consumer.j 猜你喜欢