01: /*
02: *
03: * Copyright (c) 2007, Sun Microsystems, Inc.
04: *
05: * All rights reserved.
06: *
07: * Redistribution and use in source and binary forms, with or without
08: * modification, are permitted provided that the following conditions
09: * are met:
10: *
11: * * Redistributions of source code must retain the above copyright
12: * notice, this list of conditions and the following disclaimer.
13: * * Redistributions in binary form must reproduce the above copyright
14: * notice, this list of conditions and the following disclaimer in the
15: * documentation and/or other materials provided with the distribution.
16: * * Neither the name of Sun Microsystems nor the names of its contributors
17: * may be used to endorse or promote products derived from this software
18: * without specific prior written permission.
19: *
20: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
21: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
23: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
24: * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
25: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
26: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
27: * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
28: * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
29: * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
30: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31: */
32: package socket;
33:
34: import java.io.*;
35:
36: import javax.microedition.io.*;
37: import javax.microedition.lcdui.*;
38: import javax.microedition.midlet.*;
39:
40: public class Sender extends Thread {
41: private OutputStream os;
42: private String message;
43:
44: public Sender(OutputStream os) {
45: this .os = os;
46: start();
47: }
48:
49: public synchronized void send(String msg) {
50: message = msg;
51: notify();
52: }
53:
54: public synchronized void run() {
55: while (true) {
56: // If no client to deal, wait until one connects
57: if (message == null) {
58: try {
59: wait();
60: } catch (InterruptedException e) {
61: }
62: }
63:
64: if (message == null) {
65: break;
66: }
67:
68: try {
69: os.write(message.getBytes());
70: os.write("\r\n".getBytes());
71: } catch (IOException ioe) {
72: ioe.printStackTrace();
73: }
74:
75: // Completed client handling, return handler to pool and
76: // mark for wait
77: message = null;
78: }
79: }
80:
81: public synchronized void stop() {
82: message = null;
83: notify();
84: }
85: }
|