使用arthas排查异常线程

//一页开启一个线程
        List<Future<List<SpatialTopologyItem>>> resultList = new ArrayList<>();
        for (int i = 0; i < pageCount; i++) {
            List<Integer> ids = allIds.stream().skip(i * oidBatchSize).limit(oidBatchSize).collect(Collectors.toList());
            //分批开始计算
            Future<List<SpatialTopologyItem>> future = executorService.submit(new CalTask(base, comparison, "false", ids));
            resultList.add(future);
 
        }
        for (Future<List<SpatialTopologyItem>> future : resultList) {
            try {
                //spatialTopologyItems.addAll(future.get());
                List<SpatialTopologyItem> spatialTopologyItems = future.get();
                //入临时库
                geometryIntersectMRProcessor.handResult(spatialTopologyItems, taskInstanceId, stage, jsonObject);
                //主动清理内存
                spatialTopologyItems.clear();
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
                //线程被中断后异常需要往上抛
                throw new RuntimeException(e);
            }
        }

thread 337