public synchronized void clearDisappearedJob ( ) { getCron4jJobList ( ) . stream ( ) . filter ( job -> job . isDisappeared ( ) ) . forEach ( job -> { final LaJobKey jobKey = job . getJobKey ( ) ; jobKeyJobMap . remove ( jobKey ) ; jobOrderedList . remove ( job ) ; job . getJobUnique ( ) . ifPresent ( jobUnique -> jobUniqueJobMap . remove ( jobUnique ) ) ; cron4jTaskJobMap . remove ( job . getCron4jTask ( ) ) ; } ) ; }
Clear disappeared jobs from job list if it exists .