Зависает socket при отключении WIFI

Thread ClientThread1 = new Thread(new Runnable() {
        @Override
        public void run() {
 
            for (; ; ) {
                switch (stm) {
 
                    case 2: {
 
                        // Подключение
                        System.out.println("case 2");
                        try {
 
                            s1 = null;
                            SharedPreferences sPrefr = getSharedPreferences("SettingD", MODE_PRIVATE);
                            s1 = new Socket(sPrefr.getString("Ip", ""), Integer.valueOf(sPrefr.getString("Port", "")));
                            InputStream inStream1 = s1.getInputStream();
                            OutputStream outStream = s1.getOutputStream();
                            out1 = new PrintWriter(outStream, true);
                            in1 = new Scanner(inStream1);
                            resultStr = null;
 
 
                        } catch (IOException e) {
                            e.printStackTrace();
 
                            stm = 2;
                        }
 
                        stm = 3;
 
                    }
                    break;
 
                    case 3: {
 
                        System.out.println("case 3");
 
//                        
 
                        if (in1.hasNextLine() == true) {
 
                            scann = in1.nextLine();
                            System.out.println("> " + scann);
 
                        } else {
                     
                            stm = 2;
                            if (s1 != null) {
                                try {
                                    s1.close();
                                } catch (IOException e1) {
                                    e1.printStackTrace();
                                }
                                s1 = null;
                            }
                        }
 
                    }
 
                     break;
                }
            }
        }
        });

scann = in1.nextLine();

        byte[] buffer = new byte[1024];
        ByteArrayOutputStream cs = new ByteArrayOutputStream();
        while (!Thread.currentThread().isInterrupted()) {
            try {
                int length = in.read(buffer);
                if (length == -1) {
                    //упс
                }
                cs.write(buffer, 0, length);
            } catch (IOException e) {
                //упс
            }
        }

s1.setSoTimeout(4000);