多线程学习之多线程访问共同资源（队列，多线程，锁机制）实例

模拟场景:main方法为网络请求线程（也叫生产者线程），在网络请求线程中开启四个线程（消费者线程），进行高效处理队列中的共同资源（生产者线程生产的共同资源），等待资源处理完毕，网络请求线程执行结束，响应客户端。

消费者线程体

/**
 * 
 */
package com.benxq.Queue;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;


/**
 * Created by qucf on 2015年10月22日. 
 */
public class MyThread implements Runnable{

    //多线程缓存队列
    private BlockingQueue<String> queue=new LinkedBlockingQueue<String>();
    
    //队列中的资源数
    private Integer count=0;
    
    //线程锁
    private Object object =new Object();
    
    //生产者完成标示
    private boolean flag=false;
    
    //线程构造器
    public MyThread(BlockingQueue<String> queue){
        this.queue=queue;
    }
    
    //获取线程对象
    public Object getObjectByLock(){
        return this.object;
    }
    
    //标志着生产者生产结束
    public void setFlag(){
        this.flag=true;
    }
    
    //队列数据加一个
    public void setCount(){
        //当队列小于0时 默认恢复到0
        if(count<0){
            count=0;
        }
        count++;
    }
    
    @Override
    public void run() {
        while(true){
            //获取当前线程的名字
            String threadName=Thread.currentThread().getName();
            
            //资源处理完毕 和生产者生产结束  跳出循环
            if(count==0&& flag){
                break;
            }
            
            try {
                //从队列中获取数据，如果没有数据等待100毫秒，如果100毫秒后还是没有数据 则返回null
                String pollInteger=queue.poll(1000, TimeUnit.MILLISECONDS);
                
                //如果取出的数据为空，则暂停本次循环，进行下次循环
                if(pollInteger==null){
                    continue;
                }

                //如果队列中的数据为0 则暂停本次循环执行下次循环
                if(count<=0){
                    continue;
                }
                
                //队列中的数据减1
                count--;
                
                //获取执行时间点
                SimpleDateFormat sd=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
                
                //从队列中消费数据
                System.out.println("MyThread-->"+threadName+"-->"+pollInteger+"-->"+sd.format(new Date()));
                
                
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
            
        }
        //当消费结束后 唤醒该锁锁住的所有线程
        synchronized (object) {
            object.notifyAll();
            System.out.println("唤醒线程"+Thread.currentThread().getName());
        }
    }

}

主方法（模拟网络请求）

/**
 * 
 */
package com.benxq.Queue;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by qucf on 2015年10月22日. 
 */
public class Test {

    //模拟消费线程队列
    private static BlockingQueue<String> queue=new LinkedBlockingQueue<String>();
    
    //模拟网络请求
    public static void main(String[] args) {
        
        MyThread myThread=new MyThread(queue);
        
        //线程池 开启 5个消费线程
        ExecutorService es=Executors.newFixedThreadPool(5);
        //开启5个线程
        for (int i = 0; i < 5; i++) {
            es.execute(myThread);
        }
        
        //模拟生产线程
        try {
            for (int i = 0; i <= 100; i++) {
                queue.put(i+"benxq");
                myThread.setCount();
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally{
            myThread.setFlag();
        }
        
        //生产结束后，网络请求线程被阻塞
        synchronized (myThread.getObjectByLock()) {
            try {
                myThread.getObjectByLock().wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        //当线程被唤醒后，执行完毕
        SimpleDateFormat sd=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        System.out.println("执行完毕"+sd.format(new Date()));
    }
}

测试结果

MyThread-->pool-1-thread-3-->4benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->1benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->2benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->5benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->3benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->8benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->0benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->9benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->7benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->12benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->6benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->14benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->15benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->16benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->17benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->18benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->19benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->20benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->13benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->11benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->10benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->23benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->24benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->22benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->26benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->27benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->29benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->21benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->30benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->31benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->32benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->33benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->34benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->35benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->37benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->36benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->28benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->39benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->40benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->41benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->42benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->43benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->44benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->45benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->46benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->47benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->48benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->49benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->25benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->51benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->52benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->54benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->55benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->56benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->50benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->58benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->59benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->60benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->61benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->62benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->38benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->63benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->64benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->65benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->57benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->67benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->68benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->53benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->70benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->71benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->72benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->69benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->75benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->76benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->66benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->77benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->78benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->80benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->74benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->81benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->82benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->83benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->84benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->85benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->86benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->87benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->88benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->73benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->90benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->91benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->92benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->93benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->94benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->89benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-1-->96benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->79benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-5-->98benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-3-->97benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-4-->95benxq-->2015-10-22 11:12:55
MyThread-->pool-1-thread-2-->100benxq-->2015-10-22 11:12:55
唤醒线程pool-1-thread-5
MyThread-->pool-1-thread-1-->99benxq-->2015-10-22 11:12:55
唤醒线程pool-1-thread-2
唤醒线程pool-1-thread-4
唤醒线程pool-1-thread-3
唤醒线程pool-1-thread-1
执行完毕2015-10-22 11:12:55