2 qqq778899123 qqq778899123 于 2016.02.19 09:11 提问

多线程,貌似死锁了,大家帮忙看下

我写了个三个类,一个监听服务器类Listener,一个服务请求处理类Handler,一个服务请求类Runner。
想要用Runner发送请求,Listener收到请求后交给Handler处理,Handler再返回一组数据给Runner,
现在Listener收到请求后就执行不下去了,大神们帮忙看下。

代码
Listener.java

 public class Listener implements Runnable {
    private static final int poolSize = Runtime.getRuntime()
            .availableProcessors();
    ExecutorService service;
    ServerSocket server;

    public Listener(int port) throws IOException {
        server = new ServerSocket(port);
        service = Executors.newFixedThreadPool(poolSize);
    }

    public static void main(String[] args) {// 启动监听服务器
        try {
            Thread t = new Thread(new Listener(9528));
            t.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        Socket in;
        while (true) {// 一直等待新请求进来
            try {
                in = server.accept();// 获取请求
                System.out.println("有新请求进来");
                service.submit(new Handler(in));// 处理请求
            } catch (IOException e) {
                e.printStackTrace();
                service.shutdown();
            }
        }
    }
}

Handler.java

 public class Handler implements Runnable {
    private Socket socket;

    public Handler(Socket in) {
        this.socket = in;
    }

    @Override
    public void run() {
        try {
            BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
            System.out.println(br.readLine());
            OutputStream out = socket.getOutputStream();
            out.write(new String(System.currentTimeMillis()+"").getBytes());

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}

Runner.java

 public class Runner {
    public static void main(String[] args) throws UnknownHostException, IOException {
        for(int i =0 ;i<10;i++){
            Socket s = new Socket(InetAddress.getLocalHost(),9528);

            BufferedReader reader=new BufferedReader(new InputStreamReader(s.getInputStream()));
            System.out.println(reader.readLine());
            OutputStream out=s.getOutputStream();
            out.write(new String("request"+i).getBytes());
            out.flush();
        }
    }
}


2个回答

caozhy
caozhy   Ds   Rxr 2016.02.19 09:20

in = server.accept();
这是阻塞的,如果没有连接上,它会一直卡在这里。

而且你整个流程都不对

qqq778899123
qqq778899123 哪个地方的流程写错了
接近 2 年之前 回复
chen956
chen956   2016.02.19 09:42

刚才测试了一下,是service.submit(new Handler(in));这句话好像没有开启线程,没有运行handler中的run函数,导致server.accept()一直等待

qqq778899123
qqq778899123 是有开启的,我把Runner第7、8、9句(OutputStr……开始)注释掉,Handler的run方法中第1、2句(BufferedReader..开始,)注释,程序就可以运行了
接近 2 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!