线程暂停和恢复

一个线程，在无限的循环，当有数据的时候就会被处理掉，但是如果暂时还没有数据，我们也会迭代判断有没有数据。这样就造成了浪费。我们可以让没有数据的时候暂停这个线程，当有数据进来的时候再通知线程运行，如果线程吧数据又都处理完了再让线程暂停。

这个方法功能有点像消费者，处理一个缓冲区，处理完之后阻塞，等待新数据。例如利用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();
        }
    }
}