阻塞隊列 ArrayBlockingQueue 我給自己挖了一個坑

說一句MMB,

一下午時間，

package cn.tbnb1.seckil.quene;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Callable;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpServletRequest;















import org.springframework.context.ApplicationContext;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;

import cn.tbnb1.common.utils.CommonConstant;
import cn.tbnb1.model.Goods;
import cn.tbnb1.service.redis.ICacheService;
import cn.tbnb1.utils.SpringContextUtil;


/**
 * 執行請求的工作線程
 * @author Administrator
 *
 */

public class RequestProcessorThread implements Callable<Boolean>  {
    
    
    

    /**
     * 自己監控的內存隊列
     */
    private ArrayBlockingQueue<HttpServletRequest> queue;
    public RequestProcessorThread(ArrayBlockingQueue<HttpServletRequest> queue) {
        this.queue = queue;
        
    }
    
    @Override
    public Boolean call() throws Exception {
        try {
            while(true) {
                // ArrayBlockingQueue
                // Blocking就是說明，如果隊列滿了，或者是空的，那么都會在執行操作的時候，阻塞住
                HttpServletRequest request = queue.take();
            synchronized (this) {
                ICacheService redisCacheService=(ICacheService)SpringContextUtil.getBean("redisCacheService");
                String itemId=    request.getParameter("id");//商品id
            Long res=    redisCacheService.get(CommonConstant.ITEMS_STORE+7, Long.class);
                if(res<=0L){//結束秒殺
                        redisCacheService.set(CommonConstant.QUEUE_SISZE,0L,10000);
//                        queue.clear();
//                        return true; 這句話  給自己挖的坑  ，首先我自己是這樣想的 ，結束秒殺不就 return 掉，mmb  這樣好了，call直接停止了，導致請求的線程全部hodl在這里了，


                    }else{
                        Long subtract = redisCacheService.subtract(CommonConstant.ITEMS_STORE+7);//庫存
                        Goods goods = redisCacheService.get("7", Goods.class);
                        
                        String uid = (String)request.getAttribute("Sessionid");
                        System.out.println("===========搶購結果===========: "+"小菜菜搶購"+goods.toString()); 
                        redisCacheService.subtract(CommonConstant.QUEUE_SISZE);
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return true;
    }



}