线程不会自动关闭

Question

            System.out.println("Received operation " + payload);
            if (payload.startsWith("{\"location\":")) {
                // execute the operation in another thread to allow the MQTT client to
                // finish processing this message and acknowledge receipt to the server
                Executors.newSingleThreadScheduledExecutor().execute(new Runnable() {
                    public void run() {
                        if(payload.equals("")) return;

                        try {
                            JsonObject jsonObject = new Gson().fromJson(payload, JsonObject.class);
                            String fixTime="", vehicleid="", deviceTime="", lat="", lon="", speed="",alt="", accuracy="", bearing="";
                            try{
                                String locationStr=jsonObject.get("location").toString();
                                locationStr=locationStr.substring(1, locationStr.length()-1).trim();
                                locationStr=locationStr.replace("\\", "");
                                JsonObject locationJson = new Gson().fromJson(locationStr, JsonObject.class);
                                try{
                                    long millis = Long.parseLong(locationJson.get("mTime").toString());
                                    Calendar cal = Calendar.getInstance();
                                    cal.setTimeInMillis(millis);
                                    fixTime = df.format(cal.getTime());
                                }catch(Exception ex){

                                }

                                lat=locationJson.get("mLatitude").toString();
                                lon=locationJson.get("mLongitude").toString();
                                alt=locationJson.get("mAltitude").toString();
                                speed=locationJson.get("mSpeed").toString();
                                accuracy=locationJson.get("mAccuracy").toString();
                                bearing=locationJson.get("mBearing").toString();
                            }catch(Exception ex){
                                ex.printStackTrace();
                            }

                            try{
                                String entityStr = jsonObject.get("entity").toString();
                                JsonObject entityJson = new Gson().fromJson(entityStr, JsonObject.class);
                                vehicleid = entityJson.get("id").toString();
                                vehicleid = vehicleid.replace("\"", "");
                            }catch(Exception ex){
                                ex.printStackTrace();
                            }

                            try{
                                String headerStr=jsonObject.get("header").toString();
                                JsonObject headerJson = new Gson().fromJson(headerStr, JsonObject.class);
                                String deviceTimeMsStr = headerJson.get("timestamp").toString();
                                long msTime = Long.parseLong(deviceTimeMsStr);
                                Calendar cal = Calendar.getInstance();
                                cal.setTimeInMillis(msTime);
                                deviceTime = df.format(cal.getTime());
                            }catch(Exception ex){
                                ex.printStackTrace();
                            }

                            Connection conn = null;
                            Statement stmt = null;
                            try{
                                String SQL = "INSERT INTO positions(protocol, deviceid, devicetime, fixtime, valid, latitude, longitude, altitude, speed, course, address, attributes, accuracy, network)";
                                SQL += " VALUES('osmand',(SELECT id FROM devices WHERE uniqueid = '" + vehicleid + "'),'" + deviceTime + "','" + fixTime + "',1," + lat + "," + lon + "," + alt + "," + speed + "," + bearing + ",'',''," + accuracy + ",'')";

                                Class.forName("com.mysql.jdbc.Driver");
                                conn =DriverManager.getConnection(MYSQL_SERVERURL, MYSQL_USERID, MYSQL_PASSWORD);
                                stmt = conn.createStatement();
                                stmt.executeUpdate(SQL);
                                System.out.println("Executed " + SQL);
                                return;
                            }catch(Exception ex){
                                ex.printStackTrace();
                            }finally {
                                try {
                                    if(stmt != null)
                                        conn.close();
                                } catch(SQLException se) {
                                }
                                try {
                                    if(conn != null)
                                        conn.close();
                                } catch(SQLException se) {
                                    se.printStackTrace();
                                }
                            }
                        }catch(Exception ex){
                            ex.printStackTrace();
                        }
                        finally{
                            return;
                        }
                    }
                });
            }
        }
    });

Answer 1

我建议您学习Oracle的Executors教程。和搜索堆栈溢出，查找关于此主题的许多现有问题和答案。

不要重复调用executors.newsinglethreadscheduledexecutor()。每个调用都在创建一个线程池。你永远不会关闭它们。线程仍在继续，甚至可能在应用程序终止之后。

您应该只在应用程序中实例化executor服务一次（通常）。然后将返回的ScheduledExecutorService对象保存在应用程序的某个位置。

当有任务要在后台线程上运行时，检索现有对象并安排任务。

最后，您必须关闭executor（及其支持线程池）。

关于更多的讨论，请参见我对一个非常相似的问题的回答。