问一个关于socket和线程等待接受消息的问题

shadow8424

在线程里面等待接受消息，除了while(true)以外，还有没有其他的方法了呢？
总觉着这种方法比较消耗资源。望各位大虾指点~~~

peream

因为java的线程停止方法不推荐用stop，所以任何时候都不应该出现while(true)这样的线程，这些你可以看看http://www.zdnet.com.cn/developer/code/story/0,2000081534,39214940,00.htm
这个，另外可以定义一个Object signal，保证两个线程用的是同一个signal对象，在监听的线程中用signal.wait().在发送消息的那个线程在发送完消息后，调用signal.notify() (或者notifyall)唤醒监听线程，让其知道有消息到来，读取。

shadow8424

收到，我去研究一下~~~

shadow8424

能给你所说的用wait()和notify()的例子吗？
最好带源代码的~~~
这里先谢谢了~~~

peream

更正一点，直接用Object类的notify，wait会抛异常。用UserSignal包装了一下：下面是源码：

UserSignal:

package example.cu.transfer;

public class UserSignal
{
    /**
     *
     * @throws InterruptedException
     */
    public synchronized void waitForNotify() throws InterruptedException
    {
        super.wait();
    }

    public synchronized void notifyTheWait()
    {
        super.notifyAll();
    }
}

IMsgTransfer:


package example.cu.transfer;

public interface IMsgTransfer
{   
    public void addMsg2Queue(String msg);
   
    public String getMsgFromQueue() throws InterruptedException;
}

MsgTransfer:

package example.cu.transfer;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;


public class MsgTransfer implements IMsgTransfer
{
    private static Queue<String>; msgQueue = null;

    private static UserSignal signal = null;

    public MsgTransfer()
    {
        msgQueue = new ConcurrentLinkedQueue<String>;();
        signal = new UserSignal();
    }

   
    public void addMsg2Queue(String msg)
    {
        if (msg != null)
        {
            if (msgQueue.size() >;= 30)
            {
                msgQueue.remove();
            }
            msgQueue.add(msg);
            signal.notifyTheWait();
        }
    }

   
    public String getMsgFromQueue() throws InterruptedException
    {
        String msg = null;
        if (msgQueue.isEmpty())
            signal.waitForNotify();
        msg = msgQueue.poll();
        return msg;
    }
}

TransferFactory:
package example.cu.transfer;

public class TransferFactory
{
    private static IMsgTransfer msgTransfer = null;
   
    public static IMsgTransfer getMsgTransfer()
    {
        if(msgTransfer == null)
        {
            msgTransfer = new MsgTransfer();
        }
        return msgTransfer;
    }
}


Msgproducter:

package example.cu.transfer;


public class MsgProducter
{
    private IMsgTransfer msgTransfer;
   
    public MsgProducter()
    {
        this.msgTransfer = TransferFactory.getMsgTransfer();
    }
   
    public void addMsg(String msg)
    {
        this.msgTransfer.addMsg2Queue(msg);
    }
}



MsgConsumer:

package example.cu.transfer;

public class MsgConsumer
{
    private IMsgTransfer msgTransfer;

    private GetMsgThread msgThread;

    public MsgConsumer()
    {
        this.msgThread = new GetMsgThread();
        this.msgTransfer = TransferFactory.getMsgTransfer();
    }

    public void startThread()
    {
        this.msgThread.start();
    }

    public void stopThread()
    {
        this.msgThread.stop = true;
        this.msgThread.interrupt();
    }

    class GetMsgThread extends Thread
    {
        volatile boolean stop = false;

        public void run()
        {
            while (!stop)
            {
                try
                {
                    String msg = msgTransfer.getMsgFromQueue();
                    System.out.println("In thread msg = " + msg);
                }
                catch (InterruptedException e)
                {
                    stop = true;
                }
            }
        }
    }

}

TestMain:


package example.cu.transfer;


public class TestMain
{
    public static void main(String[] args)
    {
        MsgConsumer consumer = new MsgConsumer();
        MsgProducter producter = new MsgProducter();
        
        consumer.startThread();
        for(int i = 0; i< 10;i++)
        {
            producter.addMsg("add " + i + " msg";
            try
            {
                Thread.sleep(1000);
            }
            catch (InterruptedException e)
            {               
                e.printStackTrace();
            }
        }
        consumer.stopThread();
    }
}

用Transfer模拟一个转发器，MsgProducter在获得数据后放在Transfer的队列中，MsgConsumer消费放在队列中的数据，队列中无数据时阻塞。