File tree 11 files changed +52
-10
lines changed
main/java/com/iluwatar/queue/load/leveling
test/java/com/iluwatar/queue/load/leveling
11 files changed +52
-10
lines changed Original file line number Diff line number Diff line change 1
1
@startuml
2
+ package com . iluwatar . queue . load . leveling {
3
+ class App {
4
+ - LOGGER : Logger {static}
5
+ - SHUTDOWN_TIME : int {static}
6
+ + App ()
7
+ + main(args : String[]) {static}
8
+ }
9
+ class Message {
10
+ - msg : String
11
+ + Message(msg : String)
12
+ + getMsg () : String
13
+ + toString () : String
14
+ }
15
+ class MessageQueue {
16
+ - LOGGER : Logger {static}
17
+ - blkQueue : BlockingQueue<Message>
18
+ + MessageQueue ()
19
+ + retrieveMsg () : Message
20
+ + submitMsg(msg : Message)
21
+ }
22
+ class ServiceExecutor {
23
+ - LOGGER : Logger {static}
24
+ - msgQueue : MessageQueue
25
+ + ServiceExecutor(msgQueue : MessageQueue)
26
+ + run ()
27
+ }
28
+ interface Task {
29
+ + submit (Message ) {abstract }
30
+ }
31
+ class TaskGenerator {
32
+ - LOGGER : Logger {static}
33
+ - msgCount : int
34
+ - msgQueue : MessageQueue
35
+ + TaskGenerator(msgQueue : MessageQueue, msgCount : int)
36
+ + run ()
37
+ + submit(msg : Message)
38
+ }
39
+ }
40
+ MessageQueue --> "- blkQueue " Message
41
+ ServiceExecutor --> "- msgQueue " MessageQueue
42
+ TaskGenerator --> "- msgQueue " MessageQueue
43
+ TaskGenerator ..|> Task
2
44
@enduml
Original file line number Diff line number Diff line change 21
21
* THE SOFTWARE.
22
22
*/
23
23
24
- package org .queue .load .leveling ;
24
+ package com . iluwatar .queue .load .leveling ;
25
25
26
26
import java .util .concurrent .ExecutorService ;
27
27
import java .util .concurrent .Executors ;
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
/**
26
26
* Message class with only one parameter.
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import java .util .concurrent .ArrayBlockingQueue ;
26
26
import java .util .concurrent .BlockingQueue ;
Original file line number Diff line number Diff line change 21
21
* THE SOFTWARE.
22
22
*/
23
23
24
- package org .queue .load .leveling ;
24
+ package com . iluwatar .queue .load .leveling ;
25
25
26
26
import org .slf4j .Logger ;
27
27
import org .slf4j .LoggerFactory ;
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
/**
25
25
* Task Interface.
26
26
*
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import org .slf4j .Logger ;
26
26
import org .slf4j .LoggerFactory ;
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import java .io .IOException ;
26
26
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import static org .junit .Assert .assertEquals ;
26
26
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import org .junit .Test ;
26
26
import static org .junit .Assert .assertEquals ;
Original file line number Diff line number Diff line change 20
20
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
21
21
* THE SOFTWARE.
22
22
*/
23
- package org .queue .load .leveling ;
23
+ package com . iluwatar .queue .load .leveling ;
24
24
25
25
import org .junit .Test ;
26
26
You can’t perform that action at this time.
0 commit comments