lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ScheduledFactory优化

Browse Source
This commit is contained in:
redkale
2023-12-07 15:45:02 +08:00
parent e204b60ac4
commit 8f6098834f
1 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/org/redkale/scheduling/ScheduledFactory.java
View File

@@ -27,7 +27,6 @@ import java.util.logging.Level;
import java.util.logging.Logger; import java.util.logging.Logger;
import org.redkale.annotation.Nullable; import org.redkale.annotation.Nullable;
import org.redkale.annotation.Scheduled; import org.redkale.annotation.Scheduled;
import org.redkale.source.SourceException;
import org.redkale.util.RedkaleClassLoader; import org.redkale.util.RedkaleClassLoader;
import org.redkale.util.RedkaleException; import org.redkale.util.RedkaleException;
import org.redkale.util.Utility; import org.redkale.util.Utility;
@@ -168,9 +167,9 @@ public class ScheduledFactory {
try { try {
Object obj = ref.get(); Object obj = ref.get();
if (obj != null) { if (obj != null) {
if (logger.isLoggable(Level.FINEST)) { // if (logger.isLoggable(Level.FINEST)) {
logger.log(Level.FINEST, "schedule task " + method.getDeclaringClass().getSimpleName() + "." + method.getName()); // logger.log(Level.FINEST, "schedule task " + method.getDeclaringClass().getSimpleName() + "." + method.getName());
} // }
mh.invoke(obj); mh.invoke(obj);
} }
} catch (Throwable t) { } catch (Throwable t) {
@@ -204,11 +203,25 @@ public class ScheduledFactory {
} else if (value.indexOf('#') == 0) { } else if (value.indexOf('#') == 0) {
try { try {
String fieldName = value.substring(1); String fieldName = value.substring(1);
Field field = service.getClass().getDeclaredField(fieldName); Exception ex = null;
field.setAccessible(true); Field field = null;
return field.getLong(service); Class clazz = service.getClass();
do {
try {
field = clazz.getDeclaredField(fieldName);
field.setAccessible(true);
RedkaleClassLoader.putReflectionField(clazz.getName(), field);
break;
} catch (NoSuchFieldException fe) {
ex = fe;
}
} while ((clazz = clazz.getSuperclass()) != Object.class);
if (field == null) {
throw ex;
}
return ((Number) field.get(service)).longValue();
} catch (Exception e) { } catch (Exception e) {
throw new SourceException(e); throw new RedkaleException(e);
} }
} else { } else {
return Long.parseLong(value); return Long.parseLong(value);