一个线程,在无限的循环,当有数据的时候就会被处理掉,但是如果暂时还没有数据,我们也会迭代判断有没有数据。这样就造成了浪费。我们可以让没有数据的时候暂停这个线程,当有数据进来的时候再通知线程运行,如果线程吧数据又都处理完了再让线程暂停。
这个方法功能有点像消费者,处理一个缓冲区,处理完之后阻塞,等待新数据。例如利用BlockingQueue(阻塞队列)
这里,我们用纯线程锁机制来处理。
package com.againfly.thread; import java.util.ArrayList; import java.util.List; public class ThreadDemo extends Thread{ /*判断线程是否要被阻塞暂停*/ private boolean suspended = false; /*模拟一个缓存,缓冲区*/ private List<String> list = new ArrayList<>(); /*添加新数据,如果有新数据就通知恢复线程*/ public void put(String str){ list.add(str); recover(); } @Override public void run() { while (true) { try { /*当前线程当做锁对象,如果需要阻塞,则wait*/ synchronized (this) { while (suspended) { this.wait(); } } /*当缓存,缓冲区大小为0时,暂停线程*/ if(list.size() == 0){ pause(); continue; } /*模拟消费者行为,取出一个缓冲区中的数据,并处理*/ String str = list.remove(0); System.out.println(str); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } /*暂停*/ public void pause() { this.suspended = true; } /*继续*/ public synchronized void recover() { if(suspended){ this.suspended = false; this.notify(); } } }
最新评论