Как "отключить" потоки

@Doctor_ · Регистрация: 03.02.2011

Студворк — интернет-сервис помощи студентам

Как можно оключить потоки? Клиент жмет у себя кнопку, если данная кнопка находится в списке ему дается возможность нажать еще одну. Но вот тут проблема с потоками, смотрим код. Ошибка в самом низу.

Сервер:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
public void run() {
        while (true) {
            try {
                // получаем список
                Object object = sInput.readObject();
                // получаем сигнал о готовности пользователей
                Object object2 = dInput.readInt();
                // собственно само получение списков
                if (uniqueID == 1) {
                    coordinatesPlayerOne = (List<Coordinates>) object;
                    display("List is accepted from player " + uniqueID);
                    if ((int) object2 == 1) {
                        count++;
                    }
                } else {
                    coordinatesPlayerTwo = (List<Coordinates>) object;
                    display("List is accepted from player " + uniqueID);
                    if ((int) object2 == 1) {
                        count++;
                    }
                }
                // если получил две 1, тогда первому клиенту посылается разрешение нажимать кнопки
                if (count == 2)
                    sendReady(1);
 
                // новый поток, который получает он клиента координаты нажатой кнопки
                shot = (Shot) sInputShot.readObject();
                String coord = shot.getShot();
                switch (shot.getType()) {
                case Shot.SHOT:
                    if (uniqueID == 1) {
                        // тут происходит проверка, есть ли коодинаты нажатой кнопки в уже присланых списках
                        System.out.println(uniqueID);
                        String tmp = checkCoordinates(coordinatesPlayerOne,
                                coord);
                        broadcastCoordinates(coord + tmp, 1);
                        broadcastCoordinates(coord + tmp + "ENABLE", 2);
                    } else {
                        System.out.println(uniqueID);
                        String tmp = checkCoordinates(coordinatesPlayerTwo,
                                coord);
                        broadcastCoordinates(coord + tmp, 2);
                        broadcastCoordinates(coord + tmp + "ENABLE", 1);
                    }
                    break;
                }
            } catch (IOException e) {
                display(username + " Exception reading Streams: " + e);
                break;
            } catch (ClassNotFoundException e2) {
                break;
            }
        }
        remove(id);
        close();
    }
    
    // метод который проверяет наличие коодринат в списках
    private String checkCoordinates(List<Coordinates> coordinates, String coord) {
        int xPos = Character.getNumericValue(coord.charAt(0));
        int yPos = Character.getNumericValue(coord.charAt(1));
        for (int i = 0; i < coordinates.size(); i++) {
            if (xPos == coordinates.get(i).getI()
                    && yPos == coordinates.get(i).getJ()) {
                return "" + 1 + coordinates.get(i).getS();
            }
        }
        return "0";
    }

Shot:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class Shot implements Serializable {
    public final static int SHOT = 0;
    private int type;
    private String shot;
 
    public Shot(int type, String shot) {
        this.type = type;
        this.shot = shot;
    }
 
    public int getType() {
        return type;
    }
 
    public String getShot() {
        return shot;
    }
}

Клиент:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
class Listen extends Thread {
        public void run() {
            while (true) {
                try {
                    // получение сообщения он сервера которое делает доступными все кнопки
                    String message = (String) sInput.readObject();
                    if (message.equals("#GO#")) {
                        for (int i = 0; i < 10; i++) {
                            for (int j = 0; j < 10; j++) {
                                gui.getOponentField()[i][j].setEnabled(true);
                            }
                        }
                    }
                    // зарисовка кнопки в второго клиента
                    if (message.length() == 5 && isNumeric(message)) {
                        char xPos = message.charAt(0);
                        char yPos = message.charAt(1);
                        int i = Character.getNumericValue(xPos);
                        int j = Character.getNumericValue(yPos);
                        gui.getPlayerFieldAfter()[i][j].setText("X");
                        if (Character.getNumericValue(message.charAt(2)) == 1) {
                            gui.getPlayerFieldAfter()[i][j]
                                    .setBackground(Color.yellow);
                            gui.getPlayerFieldAfter()[i][j].revalidate();
                            gui.getPlayerFieldAfter()[i][j].repaint();
                        }
                    }
                    // зарисовка клетки если такая была в списке на сервере, и дает разришение нажимать остальные кнопки
                    if (message.length() == 11) {
                        int i = Character.getNumericValue(message.charAt(0));
                        int j = Character.getNumericValue(message.charAt(1));
                        String shipType = message.charAt(3) + ""
                                + message.charAt(4);
                        if (Character.getNumericValue(message.charAt(2)) == 1) {
                            gui.getOponentField()[i][j]
                                    .setBackground(Color.yellow);
                            gui.getOponentField()[i][j].revalidate();
                            gui.getOponentField()[i][j].repaint();
                            gui.getOponentField()[i][j].setText("X");
                            // память - это где хранятся все зажатые кнопки, чтоб потом можно было восстановить все
                            memory.add(new Memory(i, j, shipType));
                            for (int x = 0; x < 10; x++) {
                                for (int y = 0; y < 10; y++) {
                                    gui.getOponentField()[x][y].setEnabled(true);
                                }
                            }                           
                        } else {
                            gui.getOponentField()[i][j].setText("X");
                            memory.add(new Memory(i, j, "X"));
                        }
                    }
                } catch (IOException ioex) {
                    ioex.printStackTrace();
                    display("Can't catch message or coordinates from server");
                    if (gui != null)
                        gui.connectionFailed();
                    break;
                } catch (ClassNotFoundException cnfe) {
                    cnfe.printStackTrace();
                }
            }
        }
    }

Как уже стало понято это все еще тот же морской бой. Ошибка вылетает тогда когда, один клиент попал по кораблю противника и по правилам ему дается возможность стрелять еще раз. У меня получается что возможность дается, но при нажатии на следующую кнопку вылетает это java.lang.String cannot be cast to java.io.ObjectStreamClass и ругается на сервер Object object = sInput.readObject();. По идеии тут получается что потоки пересикаются, он получает не то что ждет. Так вот как обрезать эти первые потоки после того как они приняли нужное количество информации (два списка и две единицы (признак готовности игроков))?

Добавлено через 4 часа 38 минут
В данный момент пришел к решению - пока списки пустые принимать object, если уже оба не пустые тогда больше не принимать ничего. Просто if написал и все.

@Atom77 · 10.02.2016, 19:02

Эх жаль доктор, что я не знаю. А то бы я тебе обязательно подсказал бы очень подробно.

@korvin_ · 10.02.2016, 22:23

Сообщение от Doctor_

но при нажатии на следующую кнопку вылетает это java.lang.String cannot be cast to java.io.ObjectStreamClass и ругается на сервер Object object = sInput.readObject();

А там в сообщении ещё название класса пишут и номер строки...

@KEKCoGEN · 10.02.2016, 22:52

Doctor_, вам бы можно было помочь если бы код был хотя бы немного читаемый. Судя по вашему описанию у вас проблема в архитектуре программы.

@Doctor_ · 11.02.2016, 08:24 **[ТС]**

Думаю стоит посмотреть на дату, когда эта тема была создана.

22.08.2013

то есть, это тогда, когда я начинал программировать.

@KEKCoGEN · 11.02.2016, 09:01

Сообщение от Doctor_

Думаю стоит посмотреть на дату

действительно, не заметил.

@korvin_ · 11.02.2016, 19:58

Не по теме:

Ай да Atom77, ай да шутник...

@Atom77 · 11.02.2016, 20:06

Понимаешь korvin Доктору с 2013 года так и никто не ответил, вот я и решил его хоть чем то поддержать.

Новые блоги и статьи Все статьи Все блоги /
http://iceja.net/ сервер решения полиномов iceja 18.01.2026 Выкатила http:/ / iceja. net/ сервер решения полиномов (находит действительные корни полиномов методом Штурма). На сайте документация по API, но скажу прямо VPS слабенький и 200 000 полиномов. . .	Первый деплой lagorue 16.01.2026 Не спеша развернул своё 1ое приложение в kubernetes. А дальше мне интересно создать 1фронтэнд приложения и 2 бэкэнд приложения развернуть 2 деплоя в кубере получится 2 сервиса и что-бы они. . .	Расчёт переходных процессов в цепи постоянного тока igorrr37 16.01.2026 / * Дана цепь постоянного тока с R, L, C, k(ключ), U, E, J. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа, решает её и находит: токи, напряжения и их 1 и 2 производные при t = 0;. . .	Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .
Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .

@Atom77 1 / 1 / 0 Регистрация: 25.01.2016 Сообщений: 61
	10.02.2016, 19:02
	Эх жаль доктор, что я не знаю. А то бы я тебе обязательно подсказал бы очень подробно. 0

@KEKCoGEN 2399 / 2224 / 565 Регистрация: 28.12.2010 Сообщений: 8,672
	10.02.2016, 22:52
	Doctor_, вам бы можно было помочь если бы код был хотя бы немного читаемый. Судя по вашему описанию у вас проблема в архитектуре программы. 0

@korvin_
	11.02.2016, 19:58
	Не по теме: Ай да Atom77, ай да шутник... 0

@Atom77 1 / 1 / 0 Регистрация: 25.01.2016 Сообщений: 61
	11.02.2016, 20:06
	Понимаешь korvin Доктору с 2013 года так и никто не ответил, вот я и решил его хоть чем то поддержать. 0