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

Browse Source
This commit is contained in:
Redkale
2022-07-02 22:10:32 +08:00
parent 927007774b
commit 00dc3ee945
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/redkale/boot/Application.java
View File

@@ -967,6 +967,7 @@ public final class Application {
} }
CacheSource loadCacheSource(final String sourceName, boolean autoMemory) { CacheSource loadCacheSource(final String sourceName, boolean autoMemory) {
long st = System.currentTimeMillis();
CacheSource old = resourceFactory.find(sourceName, CacheSource.class); CacheSource old = resourceFactory.find(sourceName, CacheSource.class);
if (old != null) return old; if (old != null) return old;
final AnyValue sourceConf = cacheResources.get(sourceName); final AnyValue sourceConf = cacheResources.get(sourceName);
@@ -977,7 +978,7 @@ public final class Application {
resourceFactory.register(sourceName, CacheSource.class, source); resourceFactory.register(sourceName, CacheSource.class, source);
resourceFactory.inject(sourceName, source); resourceFactory.inject(sourceName, source);
if (!compileMode && source instanceof Service) ((Service) source).init(sourceConf); if (!compileMode && source instanceof Service) ((Service) source).init(sourceConf);
logger.info("[" + Thread.currentThread().getName() + "] Load CacheSource resourceName = " + sourceName + ", source = " + source); logger.info("[" + Thread.currentThread().getName() + "] Load CacheSource resourceName = " + sourceName + ", source = " + source + " in " + (System.currentTimeMillis() - st) + " ms");
return source; return source;
} }
String classval = sourceConf.getValue("type"); String classval = sourceConf.getValue("type");
@@ -1019,7 +1020,7 @@ public final class Application {
resourceFactory.register(sourceName, source); resourceFactory.register(sourceName, source);
resourceFactory.inject(sourceName, source); resourceFactory.inject(sourceName, source);
if (!compileMode && source instanceof Service) ((Service) source).init(sourceConf); if (!compileMode && source instanceof Service) ((Service) source).init(sourceConf);
logger.info("[" + Thread.currentThread().getName() + "] Load CacheSource resourceName = " + sourceName + ", source = " + source); logger.info("[" + Thread.currentThread().getName() + "] Load CacheSource resourceName = " + sourceName + ", source = " + source + " in " + (System.currentTimeMillis() - st) + " ms");
return source; return source;
} catch (Exception e) { } catch (Exception e) {
logger.log(Level.SEVERE, "load application CaheSource error: " + sourceConf, e); logger.log(Level.SEVERE, "load application CaheSource error: " + sourceConf, e);

3
src/main/java/org/redkale/boot/NodeServer.java
View File

@@ -438,9 +438,10 @@ public abstract class NodeServer {
} }
} }
long et = System.currentTimeMillis();
application.servicecdl.countDown(); application.servicecdl.countDown();
application.servicecdl.await(); application.servicecdl.await();
logger.info(this.getClass().getSimpleName() + " construct services in " + (et - starts) + " ms and await " + (System.currentTimeMillis() - et) + " ms");
final StringBuilder sb = logger.isLoggable(Level.INFO) ? new StringBuilder() : null; final StringBuilder sb = logger.isLoggable(Level.INFO) ? new StringBuilder() : null;
//---------------- inject ---------------- //---------------- inject ----------------