comparison src/test/MulticastQueue.java @ 53:9250cacee347

MultiThreadTee
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Thu, 07 Jul 2011 22:29:53 +0900
parents 6eb7d0c8f11d
children
comparison
equal deleted inserted replaced
52:6eb7d0c8f11d 53:9250cacee347
12 int threads = 5; 12 int threads = 5;
13 final MulticastQueue<String> queue = new MulticastQueue<String>(); 13 final MulticastQueue<String> queue = new MulticastQueue<String>();
14 14
15 Runnable type2 = new Runnable(){ 15 Runnable type2 = new Runnable(){
16 16
17 @Override
18 public void run() 17 public void run()
19 { 18 {
20 Client<String> client = queue.newClient(); 19 Client<String> client = queue.newClient();
21 20
22 for(;;){ 21 for(;;){
32 } 31 }
33 }; 32 };
34 33
35 Runnable thread = new Runnable(){ 34 Runnable thread = new Runnable(){
36 35
37 @Override
38 public void run() 36 public void run()
39 { 37 {
40 Client<String> client = queue.newClient(); 38 Client<String> client = queue.newClient();
41 39
42 for(;;){ 40 for(;;){