多线程-wait(),notify(),notifyAll()
首先说明下：
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唤醒一个消费者线程去消费。
转载于
//www.cnblogs.com/johnnyzhao/p/10370274.html
阳光穿透心脏的1/2处
太过爱你忘了你带给我的痛
爱被打了一巴掌
￡神魔★判官ぃ
亦凉
还没有评论，来说两句吧...