猿问

我这个线程起的有没有问题

//得到socket及其它信息
private static SessionBean sessionBean = SessionBean.getInstance();

/**
 * 报文处理及生成CSV文件流程
 * @return void 无返回值
 */
public static void process(){

    //从上层sessionBean中得到一个socket,socket负责接收实时消息
    Socket s = sessionBean.getSocket();

    new Runnable() {
        public void run() {
            try {
                BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
                String data = br.readLine();
                //得到所需要的数据
                String needData = getNeedMessage(data);
                //处理所需要的数据
                dataHandle(needData);
                //生成CSV文件
                writeCsvFile();
            } catch (IOException e) {
                logger.error("报文信息读取失败");
            }
        }
    };
}


慕娘9325324
浏览 385回答 4
4回答

米脂

不太清楚你的业务场景,就只能从代码上面说了1.你并没有new Thread,只是构造了一个Runnable的实例,等于你的这个Runnable并没有被执行2.对于socket,你只是获取操作了,并没有关闭,这里也是一个隐患,关闭的时候最好是finally中关闭3.getSocket这个方法并没有看到具体的代码,是否需要同步4.process这个方法本身就是static的,为什么你还要new呢

茅侃侃

有两个问题1. process()是static的 还需要new 本类().process吗?2. 你所谓的线程都没调用start()方法 怎么能运行?

Smart猫小萌

内部类中 你可能会丢掉对s 的引用

UYOU

这个应该new Thread(new Runnable(){...run(){...}}).start()
随时随地看视频慕课网APP

相关分类

Java
我要回答