也许此代码段可以为您提供帮助。

示例

工作

 公共类CoreExampleImportJob扩展AbstractJobPerformable  {
     
      私有布尔型可终止；
     
      @Override
      public PerformResult perform（final CronJobModel cronJobModel）{
         
          尝试{
              ...
              processItems（cronJobModel，list）;
              ...
          } catch（final HttpException | RuntimeException e）{
              LOG.fatal（"发生异常：" + e.getMessage（），e）;
             
              返回新的PerformResult（CronJobResult.FAILURE，CronJobStatus.FINISHED）;
          }
         
          返回新的PerformResult（CronJobResult.SUCCESS，CronJobStatus.FINISHED）;
      }
     
      private void processItems（最终CronJobModel cronJobModel，最终列表列表）{
          emptyIfNull（list.getItems（））。stream（）。forEach（item-> {
              如果（clearAbortRequestedIfNeeded（cronJobModel））{
                  抛出新的RuntimeException（" CronJob被用户中止"）；
              }
             
              ....
          }）;
         
      }
     
      @Override
      公共布尔isAbortable（）{
          返回可终止
      }
     
      @需要
      公共无效setAbortable（最终布尔型可终止）{
          this.abortable =可终止；
      }
  }
  

春天

de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable-> clearAbortRequestedIfNeeded

  ...
  受保护的最终布尔值clearAbortRequestedIfNeeded（T myCronJob）{
          this.modelService.refresh（myCronJob）;
          if（BooleanUtils.isTrue（myCronJob.getRequestAbort（）））{
              myCronJob.setRequestAbort（（Boolean）null）;
              this.modelService.save（myCronJob）;
              返回true；
          }其他{
              返回false；
          }
      }