首先说明下:
wait(),notify(),notifyAll()不属于Thread类,而是属于Object基础类,也就是说每个对像都有wait(),notify(),notifyAll()的功能。
因为都个对像都有锁,锁是每个对像的基础,当然操作锁的方法也是最基础了。
wait:线程自动释放其占有的对象锁,并等待notify
notify:唤醒一个正在wait当前对象锁的线程,并让它拿到对象锁
notifyAll:唤醒所有正在wait前对象锁的线程
notify和notifyAll的最主要的区别是:notify只是唤醒一个正在wait当前对象锁的线程,而notifyAll唤醒所有。
值得注意的是:notify是本地方法,具体唤醒哪一个线程由虚拟机控制;notifyAll后并不是所有的线程都能马上往下执行,它们只是跳出了wait状态,接下来它们还会是竞争对象锁。
下面以生产者,消费者的例子来:
kotlin的基类是Any,类似于java中的Object,但是没有提供wait()、notify()、notifyAll()方法。但是我们依然可以通过创建Object的实例,从而调用wait()、notify()、notifyAll()方法。
我们创建三个类,分别是Message, Product, Consumer
class Message {
}
/**
* 消息生产者
* */
class Producer : Thread() {
val lock = java.lang.Object()
val messageList = ArrayList<Message>()
override fun run() {
while (true) {
Thread.sleep(5000)
val message = Message()
synchronized(lock) {
messageList.add(message);
println("added message")
lock.notify()
}
}
}
fun waitMessage():Message {
synchronized(lock) {
if (messageList.isEmpty()) {
lock.wait()//交出锁
}
return messageList.removeAt(0)
}
}
}
/**
* 消息消费者
* */
class Consumer : Thread {
var producer: Producer? = null
var name_: String? = null
// init {
// this.name_ = name_
// this.producer = producer_
// }
constructor(name_: String, producer_: Producer) {
this.name_ = name_
this.producer = producer_
}
override fun run() {
while (true) {
val msg: Message = producer!!.waitMessage()
println("Consumer $name_ get a message")
}
}
}
运行:
val producer = Producer()
producer.start()
val consumer = Consumer("consumer1",producer)
consumer.start()
消费者线程调用waitMsg去获取一个消息实体,如果msgList为空,则线程进入wait状态;生产这线程每隔5秒钟生产出体格msg实体并放入msgList列表,完成后,调用notify唤醒一个消费者线程去消费。