Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitd6b5456

Browse files
author
Chandana Amarnath
committed
Updated checkstyle errors.
1 parent52a81eb commitd6b5456

File tree

4 files changed

+22
-23
lines changed

4 files changed

+22
-23
lines changed

‎queue-load-leveling/src/main/java/org/queue/load/leveling/App.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -71,25 +71,25 @@ public static void main(String[] args) {
7171
LOGGER.info("All the TaskGenerators started.");
7272

7373
// Create three TaskGenerator threads. Each of them will submit different number of jobs.
74-
RunnabletaskRunnable_1 =newTaskGenerator(msgQueue,5);
75-
RunnabletaskRunnable_2 =newTaskGenerator(msgQueue,1);
76-
RunnabletaskRunnable_3 =newTaskGenerator(msgQueue,2);
74+
RunnabletaskRunnable1 =newTaskGenerator(msgQueue,5);
75+
RunnabletaskRunnable2 =newTaskGenerator(msgQueue,1);
76+
RunnabletaskRunnable3 =newTaskGenerator(msgQueue,2);
7777

78-
ThreadtaskGenerator_1 =newThread(taskRunnable_1,"Task_Generator_1");
79-
ThreadtaskGenerator_2 =newThread(taskRunnable_2,"Task_Generator_2");
80-
ThreadtaskGenerator_3 =newThread(taskRunnable_3,"Task_Generator_3");
78+
ThreadtaskGenerator1 =newThread(taskRunnable1,"Task_Generator_1");
79+
ThreadtaskGenerator2 =newThread(taskRunnable2,"Task_Generator_2");
80+
ThreadtaskGenerator3 =newThread(taskRunnable3,"Task_Generator_3");
8181

82-
taskGenerator_1.start();
83-
taskGenerator_2.start();
84-
taskGenerator_3.start();
82+
taskGenerator1.start();
83+
taskGenerator2.start();
84+
taskGenerator3.start();
8585

8686
LOGGER.info("Service Executor started.");
8787

8888
// First create e service which will process all the jobs.
8989
RunnablesrvRunnable =newServiceExecutor(msgQueue);
9090
ThreadsrvExec =newThread(srvRunnable,"Service_Executor_Thread");
9191
srvExec.start();
92-
}catch(Exceptione) {
92+
}catch(Exceptione) {
9393
LOGGER.error(e.getMessage());
9494
}
9595
}

‎queue-load-leveling/src/main/java/org/queue/load/leveling/MessageQueue.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -48,14 +48,13 @@ public MessageQueue() {
4848
/**
4949
* All the TaskGenerator threads will call this method to insert the
5050
* Messages in to the Blocking Queue.
51-
* @param msg
5251
*/
5352
publicvoidsubmitMsg(Messagemsg) {
5453
try {
55-
if(null !=msg) {
54+
if(null !=msg) {
5655
blkQueue.add(msg);
5756
}
58-
}catch(Exceptione) {
57+
}catch(Exceptione) {
5958
LOGGER.error(e.getMessage());
6059
}
6160
}
@@ -68,8 +67,8 @@ public void submitMsg(Message msg) {
6867
publicMessageretrieveMsg() {
6968
MessageretrievedMsg =null;
7069
try {
71-
retrievedMsg =blkQueue.poll();
72-
}catch(Exceptione) {
70+
retrievedMsg =blkQueue.poll();
71+
}catch(Exceptione) {
7372
LOGGER.error(e.getMessage());
7473
}
7574

‎queue-load-leveling/src/main/java/org/queue/load/leveling/ServiceExecutor.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,20 +47,20 @@ public ServiceExecutor(MessageQueue msgQueue) {
4747
*/
4848
publicvoidrun() {
4949
try {
50-
while(true) {
50+
while(true) {
5151
Messagemsg =msgQueue.retrieveMsg();
5252

53-
if(null !=msg) {
53+
if(null !=msg) {
5454
LOGGER.info(msg.toString() +" is served.");
5555
}else {
5656
LOGGER.info("ServiceExecutor: All tasks are executed. Waiting.");
5757
}
5858

5959
Thread.sleep(1000);
6060
}
61-
}catch(InterruptedExceptionie) {
61+
}catch(InterruptedExceptionie) {
6262
LOGGER.error(ie.getMessage());
63-
}catch(Exceptione) {
63+
}catch(Exceptione) {
6464
LOGGER.error(e.getMessage());
6565
}
6666
}

‎queue-load-leveling/src/main/java/org/queue/load/leveling/TaskGenerator.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public TaskGenerator(MessageQueue msgQueue, int msgCount) {
5454
publicvoidsubmit(Messagemsg) {
5555
try {
5656
this.msgQueue.submitMsg(msg);
57-
}catch(Exceptione) {
57+
}catch(Exceptione) {
5858
LOGGER.error(e.getMessage());
5959
}
6060
}
@@ -65,7 +65,7 @@ public void submit(Message msg) {
6565
*/
6666
publicvoidrun() {
6767
try {
68-
while(this.msgCount >0) {
68+
while(this.msgCount >0) {
6969
StringstatusMsg ="Message-" +this.msgCount +" submitted by " +Thread.currentThread().getName();
7070
MessagenewMessage =newMessage(statusMsg);
7171
this.submit(newMessage);
@@ -78,9 +78,9 @@ public void run() {
7878
// Make the current thread to sleep after every Message submission.
7979
Thread.sleep(1000);
8080
}
81-
}catch(InterruptedExceptionie) {
81+
}catch(InterruptedExceptionie) {
8282
LOGGER.error(ie.getMessage());
83-
}catch(Exceptione) {
83+
}catch(Exceptione) {
8484
LOGGER.error(e.getMessage());
8585
}
8686
}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp