1) Test Code
@Test
public void non_spring_non_blocking() throws InterruptedException{
CollectActor actor = TypedActor.newInstance(CollectActor.class,CollectActorImpl.class);
actor.setTimeAgentLogService(timeAgentLogService);
actor.setTimeAreaLogService(timeAreaLogService);
actor.setTimeLanguageLogService(timeLanguageLogService);
actor.setCollectorService(collectorService);
int count = 1;
do{
System.out.println(count + ") start...");
Thread.sleep(10);
RawLog codeLog = LawLogFixture.get();
CodeCreator codeCreator = CodeCreator.findCodeCreatorsByShortUrlEquals("B").getSingleResult();
codeLog.setCodeCreatorId(codeCreator.getId()); // id 전달
codeLog.setWriteDate(new Date());
actor.collectNonBlocking(codeLog);
count++;
}while(count < 6);
TypedActor.stop(actor);
}
@Autowired private CollectActor collectActor;
@Test
public void spring_non_blocking() throws InterruptedException{
collectActor.setTimeAgentLogService(timeAgentLogService);
collectActor.setTimeAreaLogService(timeAreaLogService);
collectActor.setTimeLanguageLogService(timeLanguageLogService);
int count = 1;
do{
System.out.println(count + ") start...");
Thread.sleep(10);
RawLog codeLog = LawLogFixture.get();
CodeCreator codeCreator = CodeCreator.findCodeCreatorsByShortUrlEquals("B").getSingleResult();
codeLog.setCodeCreatorId(codeCreator.getId()); // id 전달
codeLog.setWriteDate(new Date());
collectActor.collectNonBlocking(codeLog);
count++;
}while(count < 6);
TypedActor.stop(collectActor);
}
2) 결과
1) start...
2) start...
[LOG] None Blocking start-----------------------------------------------------
3) start...
4) start...
5) start...
[log]AgentLog insert
[log]LanguageLog insert
[log]AreaLog insert
[LOG] None Blocking end-----------------------------------------------------
[LOG] None Blocking start-----------------------------------------------------
[log]AgentLog insert
[log]LanguageLog insert
[log]AreaLog insert
[LOG] None Blocking end-----------------------------------------------------
[LOG] None Blocking start-----------------------------------------------------
[log]AgentLog insert
[log]LanguageLog insert
[log]AreaLog insert
[LOG] None Blocking end-----------------------------------------------------
[LOG] None Blocking start-----------------------------------------------------
[log]AgentLog insert
[log]LanguageLog insert
[log]AreaLog insert
[LOG] None Blocking end-----------------------------------------------------
[LOG] None Blocking start-----------------------------------------------------
[log]AgentLog insert
[log]LanguageLog insert
[log]AreaLog insert
[LOG] None Blocking end-----------------------------------------------------
댓글을 달아 주세요