sender.java

我自己写的蓝牙例子

import java.io.*;

/**该类为终结点的消息发送类
* 功能是不断的判断终结点有没有消息要发送peekString（）
*，有则取得进行发送，无则停5秒继续检测；
*
*/

public class Sender implements Runnable
{
	public EndPoint endpt;
	
	private boolean done = false;

  public Sender()
  {
  }
  
    public void stop()
  {
    done = true;
  }
  
    public void run()
  {
    try
    {
      DataOutputStream dataout = endpt.con.openDataOutputStream();
      while( !done )
      {
        if ( ! endpt.peekString()  )
        {
          synchronized (this) {
            this.wait(5000);
          }
        }
        ChatPacket s = endpt.getString();
        if ( s != null )
        {
          dataout.writeInt(s.signal);
          dataout.writeUTF(s.msg );
          dataout.flush();
        }

        if ( s != null && s.signal == NetLayer.SIGNAL_TERMINATE )
        {
          stop();
        }

      } 
      dataout.close();
    } catch (Exception e)
    {
      e.printStackTrace();
    }
  }
  
  
	
}