并发处理设置返回值

xumiao
1 parent eb0af48a
Showing 1 changed file with 4 additions and 2 deletions
src/main/java/com/huaheng/framework/web/controller/BaseController.java
@@ -235,6 +235,7 @@ public class BaseController
     public AjaxResult exec(Object key,MultiProcessListener multiProcessListener){
         ReentrantLock mutex4Key = null;
         ReentrantLock mutexIncache;
+        AjaxResult ajaxResult=null;
         do {
             if (mutex4Key != null) {
                 mutex4Key.unlock();
@@ -249,16 +250,17 @@ public class BaseController
              */
         }while (mutexIncache ==null|| mutexIncache !=mutex4Key);
         try {
-            multiProcessListener.doProcess();
+            ajaxResult = multiProcessListener.doProcess();
         }catch (Exception e){
             e.printStackTrace();
+            ajaxResult = AjaxResult.error(e.getMessage());
         }finally {
             if (mutex4Key.getQueueLength()==0) {
                 mutexCache.remove(key);
             }
             mutex4Key.unlock();
         }
-        return AjaxResult.success();
+        return ajaxResult;
     }
  
     public interface MultiProcessListener {