@ -11,7 +11,6 @@ import org.slf4j.LoggerFactory;
import java.sql.Connection ; import java.sql.Connection ;
import java.sql.PreparedStatement ; import java.sql.PreparedStatement ;
import java.sql.SQLException ;
import java.util.* ; import java.util.* ;
import java.util.concurrent.ConcurrentHashMap ; import java.util.concurrent.ConcurrentHashMap ;
import java.util.concurrent.TimeUnit ; import java.util.concurrent.TimeUnit ;
@ -44,7 +43,7 @@ public class JobScheduleHelper {
try {
try {
TimeUnit . MILLISECONDS . sleep ( 5000 - System . currentTimeMillis ( ) % 1000 ) ;
TimeUnit . MILLISECONDS . sleep ( 5000 - System . currentTimeMillis ( ) % 1000 ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
@ -150,7 +149,7 @@ public class JobScheduleHelper {
// tx stop
// tx stop
} catch ( Exception e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( ">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}" , e ) ;
logger . error ( ">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread error:{}" , e ) ;
}
}
@ -160,21 +159,21 @@ public class JobScheduleHelper {
if ( conn ! = null ) {
if ( conn ! = null ) {
try {
try {
conn . commit ( ) ;
conn . commit ( ) ;
} catch ( SQLException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
}
}
try {
try {
conn . setAutoCommit ( connAutoCommit ) ;
conn . setAutoCommit ( connAutoCommit ) ;
} catch ( SQLException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
}
}
try {
try {
conn . close ( ) ;
conn . close ( ) ;
} catch ( SQLException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
@ -185,7 +184,7 @@ public class JobScheduleHelper {
if ( null ! = preparedStatement ) {
if ( null ! = preparedStatement ) {
try {
try {
preparedStatement . close ( ) ;
preparedStatement . close ( ) ;
} catch ( SQLException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
@ -200,7 +199,7 @@ public class JobScheduleHelper {
try {
try {
// pre-read period: success > scan each second; fail > skip this period;
// pre-read period: success > scan each second; fail > skip this period;
TimeUnit . MILLISECONDS . sleep ( ( preReadSuc ? 1000 : PRE_READ_MS ) - System . currentTimeMillis ( ) % 1000 ) ;
TimeUnit . MILLISECONDS . sleep ( ( preReadSuc ? 1000 : PRE_READ_MS ) - System . currentTimeMillis ( ) % 1000 ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
if ( ! scheduleThreadToStop ) {
if ( ! scheduleThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
@ -227,7 +226,7 @@ public class JobScheduleHelper {
// align second
// align second
try {
try {
TimeUnit . MILLISECONDS . sleep ( 1000 - System . currentTimeMillis ( ) % 1000 ) ;
TimeUnit . MILLISECONDS . sleep ( 1000 - System . currentTimeMillis ( ) % 1000 ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
if ( ! ringThreadToStop ) {
if ( ! ringThreadToStop ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
@ -255,7 +254,7 @@ public class JobScheduleHelper {
// clear
// clear
ringItemData . clear ( ) ;
ringItemData . clear ( ) ;
}
}
} catch ( Exception e ) {
} catch ( Throwable e ) {
if ( ! ringThreadToStop ) {
if ( ! ringThreadToStop ) {
logger . error ( ">>>>>>>>>>> xxl-job, JobScheduleHelper#ringThread error:{}" , e ) ;
logger . error ( ">>>>>>>>>>> xxl-job, JobScheduleHelper#ringThread error:{}" , e ) ;
}
}
@ -269,17 +268,28 @@ public class JobScheduleHelper {
ringThread . start ( ) ;
ringThread . start ( ) ;
}
}
private void refreshNextValidTime ( XxlJobInfo jobInfo , Date fromTime ) throws Exception {
private void refreshNextValidTime ( XxlJobInfo jobInfo , Date fromTime ) {
Date nextValidTime = generateNextValidTime ( jobInfo , fromTime ) ;
try {
if ( nextValidTime ! = null ) {
Date nextValidTime = generateNextValidTime ( jobInfo , fromTime ) ;
jobInfo . setTriggerLastTime ( jobInfo . getTriggerNextTime ( ) ) ;
if ( nextValidTime ! = null ) {
jobInfo . setTriggerNextTime ( nextValidTime . getTime ( ) ) ;
jobInfo . setTriggerLastTime ( jobInfo . getTriggerNextTime ( ) ) ;
} else {
jobInfo . setTriggerNextTime ( nextValidTime . getTime ( ) ) ;
} else {
// generateNextValidTime fail, stop job
jobInfo . setTriggerStatus ( 0 ) ;
jobInfo . setTriggerLastTime ( 0 ) ;
jobInfo . setTriggerNextTime ( 0 ) ;
logger . error ( ">>>>>>>>>>> xxl-job, refreshNextValidTime fail for job: jobId={}, scheduleType={}, scheduleConf={}" ,
jobInfo . getId ( ) , jobInfo . getScheduleType ( ) , jobInfo . getScheduleConf ( ) ) ;
}
} catch ( Throwable e ) {
// generateNextValidTime error, stop job
jobInfo . setTriggerStatus ( 0 ) ;
jobInfo . setTriggerStatus ( 0 ) ;
jobInfo . setTriggerLastTime ( 0 ) ;
jobInfo . setTriggerLastTime ( 0 ) ;
jobInfo . setTriggerNextTime ( 0 ) ;
jobInfo . setTriggerNextTime ( 0 ) ;
logger . warn ( ">>>>>>>>>>> xxl-job, refreshNextValidTime fail for job: jobId={}, scheduleType={}, scheduleConf={}" ,
jobInfo . getId ( ) , jobInfo . getScheduleType ( ) , jobInfo . getScheduleConf ( ) ) ;
logger . error ( ">>>>>>>>>>> xxl-job, refreshNextValidTime error for job: jobId={}, scheduleType={}, scheduleConf={}" ,
jobInfo . getId ( ) , jobInfo . getScheduleType ( ) , jobInfo . getScheduleConf ( ) , e ) ;
}
}
}
}
@ -301,7 +311,7 @@ public class JobScheduleHelper {
scheduleThreadToStop = true ;
scheduleThreadToStop = true ;
try {
try {
TimeUnit . SECONDS . sleep ( 1 ) ; // wait
TimeUnit . SECONDS . sleep ( 1 ) ; // wait
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
if ( scheduleThread . getState ( ) ! = Thread . State . TERMINATED ) {
if ( scheduleThread . getState ( ) ! = Thread . State . TERMINATED ) {
@ -309,7 +319,7 @@ public class JobScheduleHelper {
scheduleThread . interrupt ( ) ;
scheduleThread . interrupt ( ) ;
try {
try {
scheduleThread . join ( ) ;
scheduleThread . join ( ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
}
}
@ -328,7 +338,7 @@ public class JobScheduleHelper {
if ( hasRingData ) {
if ( hasRingData ) {
try {
try {
TimeUnit . SECONDS . sleep ( 8 ) ;
TimeUnit . SECONDS . sleep ( 8 ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
}
}
@ -337,7 +347,7 @@ public class JobScheduleHelper {
ringThreadToStop = true ;
ringThreadToStop = true ;
try {
try {
TimeUnit . SECONDS . sleep ( 1 ) ;
TimeUnit . SECONDS . sleep ( 1 ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
if ( ringThread . getState ( ) ! = Thread . State . TERMINATED ) {
if ( ringThread . getState ( ) ! = Thread . State . TERMINATED ) {
@ -345,7 +355,7 @@ public class JobScheduleHelper {
ringThread . interrupt ( ) ;
ringThread . interrupt ( ) ;
try {
try {
ringThread . join ( ) ;
ringThread . join ( ) ;
} catch ( InterruptedException e ) {
} catch ( Throwable e ) {
logger . error ( e . getMessage ( ) , e ) ;
logger . error ( e . getMessage ( ) , e ) ;
}
}
}
}
许雪里
2 years ago
committed by
GitHub
