问Android:如何制作等待服务器消息并更新UI的线程？

EN

import java.io.IOException;
import java.io.InputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.UnknownHostException;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * Created by 41264 on 04/23/17.
 */

public class Client implements Runnable{
   final  CopyOnWriteArrayList<MsgListener> listeners = new CopyOnWriteArrayList<>();
    @Override
    public void run() {
        Socket socket = new Socket();
        try {
            int yourPort = 0;
            SocketAddress address = new InetSocketAddress("your ip",yourPort);
            socket.connect(address);
            int your_buffer_size = 1024;
            byte[] buffers = new byte[your_buffer_size];
            InputStream is = socket.getInputStream();
            int resultLength;
            String msg;
            while(true){
                resultLength = is.read(buffers);
                msg = new String(buffers,0,resultLength);
                if(listeners.size() != 0){
                    for(MsgListener msgListener: listeners){
                        msgListener.onMsgRecived(msg);
                    }
                }
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public void addListener(MsgListener listener){
        listeners.add(listener);
    }
    public void removeListener(MsgListener listener){
        listeners.remove(listener);
    }

    public interface MsgListener{
        void onMsgRecived(String msg);
    }
}

package com.example.a41264.myapplication;

import android.app.Activity;
import android.util.Log;

/**
 * Created by 41264 on 04/23/17.
 */

public class YourActivity extends Activity{

    private Client client; //you need to get your clent;

    private Client.MsgListener msgListener = new Client.MsgListener() {
        @Override
        public void onMsgRecived(final String msg) {
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    //do your own work in main thread
                    Log.i("tag",msg);
                }
            });
        }
    };

    @Override
    protected void onRestart() {
        super.onRestart();
        client.addListener(msgListener);
    }

    @Override
    protected void onStop() {
        super.onStop();
        client.removeListener(msgListener);
    }
}