Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.83/6: Рейтинг темы: голосов - 6, средняя оценка - 4.83
 Аватар для Norby
66 / 66 / 5
Регистрация: 12.03.2008
Сообщений: 392

Две оболочки для одного потока.

15.09.2011, 17:14. Показов 1190. Ответов 9
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Есть InputStream, который передается в два метода. Первый вычитывает первую строку (до '\n'), второй все остальные строки. Конец данных обозначет двумя подряд '\n'. Выглядит код примерно так:
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
//в вызывающем коде
InputStream is = socket.getInputStream();
method1(is);
method2(is);
 
void method1(InputStream is){
    InputStreamReader isr = new InputStreamReader(is);
    StringBuilder buf = new StringBuilder();
    char c;
    while ((c = (char) isr.read()) != '\n') {
        buf.append(c);
    }
    //обработка строки
}
 
void method2(InputStream is){
    InputStreamReader isr = new InputStreamReader(is);
    StringBuilder buf = new StringBuilder();
    char c;
    while (true) {
        while ((c = (char) isr.read()) != '\n') { //Тут зависает при чтении из потока
            buf.append(c);
        }
        if(buf.length() == 0) break;
        //Обработка строки
    }
}
В указанном месте программа виснет. Не могу никак понять почему. Первый метод отрабатывает нормально. Может ли быть это из-за того, что на одном потоке создаются две обертки? Может нужно использовать не InputStreamReader, а другой тип потока?
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
15.09.2011, 17:14
Ответы с готовыми решениями:

Как из одного потока узнать состояние другого потока
Подскажите пожалуйста, как из одного потока узнать, что другой поток еще не запущен. Например, второй поток формируется в классе...

Вызывть метод одного потока из другого потока
Здравствуйте, подскажите пожалуйста, как можно реализовать такую штуку : есть один поток(1), который вызывает метод у обьекта, этот...

Две задачи для одного поля
Здравствуйте. Такая вот проблема, вернее даже две: В данном варианте в ЗапросОтсутствующие вычисляется срок отсутствия при заполнении...

9
 Аватар для mutagen
2587 / 2260 / 257
Регистрация: 14.09.2011
Сообщений: 5,185
Записей в блоге: 18
15.09.2011, 19:11
скорее всего это следствие synchronize lock

надо в первом методе в long count сохранить количество прочитанных char, потом isr.close();

потом во втором методе isr.skip(count) и когда isr.ready() начинать читать
0
 Аватар для Norby
66 / 66 / 5
Регистрация: 12.03.2008
Сообщений: 392
15.09.2011, 19:27  [ТС]
Цитата Сообщение от mutagen Посмотреть сообщение
скорее всего это следствие synchronize lock

надо в первом методе в long count сохранить количество прочитанных char, потом isr.close();

потом во втором методе isr.skip(count) и когда isr.ready() начинать читать
Если я закрою поток, закроется и исходный поток сокета. Так что во втором методе уже нельзя будет читать.
0
 Аватар для mutagen
2587 / 2260 / 257
Регистрация: 14.09.2011
Сообщений: 5,185
Записей в блоге: 18
15.09.2011, 19:34
Цитата Сообщение от Norby Посмотреть сообщение
Если я закрою поток, закроется и исходный поток сокета. Так что во втором методе уже нельзя будет читать.
можно тогда попробовать занулять в первом методе InputStreamReader чтобы он снял lock с is

хотя, так как ты создаешь внутри метода новый ридер, то его закрытие не должно приводить к закрытию is
0
 Аватар для Norby
66 / 66 / 5
Регистрация: 12.03.2008
Сообщений: 392
15.09.2011, 19:42  [ТС]
Цитата Сообщение от mutagen Посмотреть сообщение
можно тогда попробовать занулять в первом методе InputStreamReader чтобы он снял lock с isis
А он разве вообще синхронизирован?

Цитата Сообщение от mutagen Посмотреть сообщение
хотя, так как ты создаешь внутри метода новый ридер, то его закрытие не должно приводить к закрытию is
Уж поверь, приводит.
0
 Аватар для mutagen
2587 / 2260 / 257
Регистрация: 14.09.2011
Сообщений: 5,185
Записей в блоге: 18
15.09.2011, 20:15
Цитата Сообщение от Norby Посмотреть сообщение
А он разве вообще синхронизирован?
Уж поверь, приводит.
он наследуется от ридера а тот ставит лок

попробовал я сделать без создания стрим ридера

Java
1
2
3
4
5
6
7
8
9
10
11
void method1(InputStream is) throws IOException {
        long count = 0L;
        char c;
        while ((c = (char) is.read()) != '\n') {
            count++;
            System.out.println("char=" + c + " count = " + count);
            if (count == 100) {
                break;
            }
        }
    }
так не блокирует, проверь
1
 Аватар для Norby
66 / 66 / 5
Регистрация: 12.03.2008
Сообщений: 392
15.09.2011, 20:48  [ТС]
Да, не блокирует. А как быть в таком случае с русскими буквами и с различными кодировками вообще?
0
 Аватар для mutagen
2587 / 2260 / 257
Регистрация: 14.09.2011
Сообщений: 5,185
Записей в блоге: 18
15.09.2011, 23:32
может лучше пробросить всё что из сокета сквозь String сразу с декодированием кодировки, а уж потом распарсить на строки и т.д.? Если конечно память позволяет.

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
    
 
// charset = "UTF-8"; etc...
public String convertStreamToString(InputStream is, String charset) throws IOException {
   if (is != null) {
   StringWriter writer = new StringWriter();
   char[] buffer = new char[1024];
   try {
      BufferedReader reader = new BufferedReader(new InputStreamReader(is, charset));
      int n;
      while ((n = reader.read(buffer)) != -1) {
         writer.write(buffer, 0, n);
      }
   } finally {
      is.close();
   }
   return writer.toString();
   } else {
      return "";
   }
}
1
 Аватар для Skipy
2000 / 1427 / 92
Регистрация: 25.11.2010
Сообщений: 3,611
16.09.2011, 14:32
А что, передавать сразу InputStreamReader нельзя было? Чтобы два раза его не создавать...
1
 Аватар для mutagen
2587 / 2260 / 257
Регистрация: 14.09.2011
Сообщений: 5,185
Записей в блоге: 18
16.09.2011, 16:14
Цитата Сообщение от Skipy Посмотреть сообщение
А что, передавать сразу InputStreamReader нельзя было? Чтобы два раза его не создавать...
скорее всего 2 раза вообще не надо, нужно создать 2 обработчика строк и потом
в процессе обработки строки обработчиком 1 из потока методом 1, по достижению события "\n",
переключиться на 2 обработчик строки тригером, так будет немного более обьектнее и экономнее в создании стринг билдеров и циклов while, неизвестно в конечном итоге сколько раз эти методы будут вызываться
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
16.09.2011, 16:14
Помогаю со студенческими работами здесь

Две джумлы для одного домена
Добрый день! Скажите, как сделать для одного сайта две джумлы?

Две переменные для одного экземпляра
Здравствуйте! В ходе изучения ЯП C#, наткнулся на интересный и не понятный для меня момент. Раньше думал что Класс - это полностью...

Две кнопки для чтения одного файла
Здравствуйте :) нужно реализовать программу в windows forms. у меня есть кнопки, как сделать так, чтобы открывался один и тот же файл,...

Определить вероятность того, что будет выбрано две карты одного значения, а две - другого
Из колоды, в которой содержится 36 карт, выбирается 4 карты, причем каждая из них после определения масти и значения возвращается в...

Один ПК, две сетевухи, две сетки, две папки для общего доступа
Здравствуйте! В одном здании имеем две разделенные физически локальные сети. Есть возможность использовать на одном ПК две сетевухи....


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
10
Ответ Создать тему
Новые блоги и статьи
Автоматическое создание документа при проведении другого документа
Maks 29.03.2026
Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .
Настройка движения справочника по регистру сведений
Maks 29.03.2026
Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .
Автозаполнение реквизита при выборе элемента справочника
Maks 27.03.2026
Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .
Сумматор с применением элементов трёх состояний.
Hrethgir 26.03.2026
Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .
Автозаполнение реквизитов при создании документа
Maks 26.03.2026
Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .
Команды формы и диалоговое окно
Maks 26.03.2026
1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .
Кому нужен AOT?
DevAlt 26.03.2026
Решил сделать простой ланчер Написал заготовку: dotnet new console --aot -o UrlHandler var items = args. Split(":"); var tag = items; var id = items; var executable = args;. . .
Отправка уведомления на почту при создании или изменении элементов справочника
Maks 24.03.2026
Программная отправка письма электронной почты на примере типового справочника "Склады" в конфигурации БП3. Перед реализацией необходимо выполнить настройку системной учетной записи электронной. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru