请求完成时如何获取会话

Question

当我的请求出现在我的控制器上，executorService创建一个线程池并创建一些线程来执行某些逻辑时，我的请求返回到Browser。我的问题从这里开始，运行在服务器端的线程需要session对象，线程得到的session为null。下面是代码，请给出一些合适的解决方案，这样我就可以在请求完成后得到会话值。

@RequestMapping（值=“/expandAllController”,方法=RequestMethod.Post）public@ResponseBody void expandAllController(@RequestParam final String[]controllerList,final HttpServletRequest请求）{

     int listSize=controllerList.length;
     BlockingQueue controllerDataQueue=cacheUtility.initBlockingQueue(listSize);
     ExecutorService executor=Executors.newCachedThreadPool();
     for(String controllerID:controllerList){
     executor.submit(new producer(controllerID,request,controllerDataQueue));
     }
     executor.shutdown();
     try {
        executor.awaitTermination(10, TimeUnit.MINUTES);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

     // data fetching Thread 


}

private class producer implements Runnable{

    Object responseObj=null;
    String controllerID;
    HttpServletRequest request;
    BlockingQueue controllerDataQueue;
          producer(String controllerID ,HttpServletRequest request, BlockingQueue controllerDataQueue ){
              this.controllerDataQueue=controllerDataQueue;
              this.controllerID=controllerID;
              this.request=request;
          }
         @Override
            public void run() {
                int ThreadCount=0;
                final HttpSession session = request.getSession();
    final CommonSettings commonSettings = CommonSettings
            .getInstance(session);
                    // for(String controllerID:controllerList){
                         controllerData.setControllerId(controllerID);

                         responseObj=expandController(controllerData,session);
                         if(responseObj!=null){
                             try {
                                controllerDataQueue.put(responseObj);

                                ThreadCount++;
                            } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            }
                         }

                     }
                }

Answer 1

直接从controller方法在会话中存储一个空容器（例如，同步的集或列表），然后将此容器传递给每个任务，并使任务将它们的响应添加到容器中。

另外，考虑重用始终相同的线程池。总是开始一个新的是浪费资源。如果有太多的请求进入，那么并行运行的线程数量就会太多，而这正是线程池所要避免的。