KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > tc > test > server > appserver > load > RequestQueueHandler


1 /*
2  * All content copyright (c) 2003-2006 Terracotta, Inc., except as may otherwise be noted in a separate copyright notice. All rights reserved.
3  */
4 package com.tc.test.server.appserver.load;
5
6 import EDU.oswego.cs.dl.util.concurrent.LinkedQueue;
7
8 import com.tc.test.server.util.HttpUtil;
9
10 public class RequestQueueHandler extends Thread JavaDoc {
11
12   private final LinkedQueue queue;
13
14   public RequestQueueHandler(LinkedQueue queue) {
15     this.queue = queue;
16   }
17
18   public void run() {
19     while (true) {
20       try {
21         Object JavaDoc obj = this.queue.take();
22         if (obj instanceof ExitRequest) {
23           return;
24         } else if (obj instanceof Request) {
25           Request request = (Request) obj;
26           request.setExitQueueTime();
27           HttpUtil.getInt(request.getUrl(), request.getClient());
28           request.setProcessCompletionTime();
29         } else {
30           throw new AssertionError JavaDoc("EventQueue was populated with a non-Request object.");
31         }
32       } catch (Exception JavaDoc e) {
33         throw new RuntimeException JavaDoc(e);
34       }
35     }
36   }
37 }
38
Popular Tags