VPF::чтение из потока без задержки ожидания данных

AndryG

Дата 30.3.2010, 12:57 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Доброго.

Код


while (true) {
    if (scanner.hasNextLine()) {
        input = scanner.nextLine(); // здесь проблема
        cmd(input);
    }
    perform();
}

Нужно в цикле постоянно вызывать perform(), если есть в потоке данные - обработать их.

При использовании Scanner, выполнение останавливается, пока не ввести данные в поток.
Если использовать InputStreamReader, то задержки нет, но в консоли не отображаются вводимые данные. Появляются только при нажатии Enter.

Подскажите, пжлст, как ? smile

РЕШЕНИЕ

Цитата

А может создать класс, который в отдельной нити будет читать поток ввода и в представлять его в виде очереди строк для основного потока?

Реализация от LSD http://forum.vingrad.ru/index.php?showtopi...t&p=2126941

Это сообщение отредактировал(а) AndryG - 31.3.2010, 17:10

LSD

Дата 30.3.2010, 13:25 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

А нижележащий поток доступен?

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

AndryG

Дата 30.3.2010, 16:56 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Нижележащий - консоль (сейчас).

Моему классу нужен поток ввода.
Я хочу научить его работать как с консоли( сейчас классу дается такой поток new InputStreamReader(System.in, "WINDOWS-1251")
так и с GUI - из строки ввода.

Вот и надо найти наименьший общий делитель для этих двух вариантов источников данных. (дальше предполагается и работа через сокеты)

LSD

Дата 30.3.2010, 17:08 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Код


inputStream.available() > 0

не блокируется, но не совсем понятно когда там будет полная строка. Может стоит сделать 2 потока?

--------------------

MisterCleric

Дата 30.3.2010, 17:38 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1043
Регистрация: 16.2.2006
Где: Харьков, Украина

Репутация: 5
Всего: 38

А смотри вот на такую реализацию. Которая пока работает и не дает сбоев:

Код


 void write(byte[] request) throws ConnectionException {
        try {
            socketOutputStream.write(request);
            socketOutputStream.flush();
        } catch (IOException e) {
            throw new ConnectionException("Can't write to socket", e);
        }
    }

/* int available() throws ConnectionException {
            try {
                return socketInputStream.available();
            } catch (IOException e) {
                throw new ConnectionException("Socket isn't available", e);
            }
        }
    */
  
    byte[] read() throws IOException {
        byte[] bytes = new byte[1024 * 4];

        ByteArrayOutputStream buffer = new ByteArrayOutputStream();

        int bytesRead = socketInputStream.read(bytes);
        if (bytesRead <= 0) {
            throw new ConnectionException("Processing close session!");
        } else {
            buffer.write(bytes, 0, bytesRead);
        }

        return buffer.toByteArray();
    }

Размер буфера выбран достаточно большим, так как сообщения не большие гоняются.
Закометированый метод реально не работает. Так как сразу читает а что там есть и получает "-1", т.е. ничего нет. А так сторона еще и не пыталась писать в поток. Вот и пришлось сидеть на read, пока в потоке не появится сообщение.

Это сообщение отредактировал(а) MisterCleric - 30.3.2010, 17:38

--------------------

ПРИШЕЛ, УВИДЕЛ - ПЕРЕПИСАЛ...

AndryG

Дата 30.3.2010, 19:15 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

LSD, Вы имеете ввиду "нити" ... потеряюсь я в них, пока smile

Если посадить обработку ввода в отдельный поток (нить), то по обработке будет выводится куча инфы + изменения в кучке объектов ... и тут же команды с консоли. Я понимаю, что корректная синхронизация всё решит ... но это многовато для первой задачки на java smile

А может создать класс, который в отдельной нити будет читать поток ввода и в представлять его в виде очереди строк для основного потока?

MisterCleric, "Вот и пришлось сидеть на read, пока в потоке не появится сообщение." мне как-раз и не подходит - мне надо постоянно крутить perform() ... и, мимоходом, обрабатывать консольный ввод.

LSD

Дата 30.3.2010, 19:42 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(AndryG @ 30.3.2010, 20:15

)

Хороший вариант, заодно он может его и парсить например (если нужно).

--------------------

AndryG

Дата 30.3.2010, 20:26 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Меня прет

запихнул метод perform() в свою нить ... и усё "заработало".
Мой "Планировщик заданий" выкинул первое уведомление smile

Код

    private Thread performer;

    public void run() throws IOException {
        // отдельная нить для обработчика
        this.performer = new Thread(new Runnable() {
            public void run() {
                while (true) {
                    try {
                        Thread.sleep(250);
                        Editor.this.tasks.perform();
                    } catch (TaskManagerException e) {
                        // затычка. Надо смотреть, что за исключения и что вообще с ними делать?!
                        System.out.println(e.getMessage());
                    } catch (InterruptedException e) {
                        System.out.println("PERFORMER END!");
                        break;
                    }
                }
            }
        });
        performer.start();
        cmdVersion("");cmdHelp("");tasks.setEnabled(true);
        // цикл для редактора
        while (true) {
            print("\nTaskManager>");
            try {
                cmd(scanner.nextLine());
            } catch (TaskManagerTerminate e) {
                performer.interrupt();
                break;
            } catch (TaskManagerException e) {
                error(e.getMessage());
            }
        }
    }

Теперь, получается, надо пройтись по всему коду и думать о синхронизации. Не представляю как это :(

Это сообщение отредактировал(а) AndryG - 30.3.2010, 20:26

LSD

Дата 31.3.2010, 16:33 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Не надо никакой синхронизации, достаточно использовать синхронизированную очередь.

Код


public class Test
{
  public static final Logger logger = Logger.getLogger("test");

  public static void main(String[] args) throws Exception
  {
    ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(100);
    AtomicBoolean running = new AtomicBoolean(true);
    InputParser parser = new InputParser(System.in, queue, running);
    InputProcessor processor = new InputProcessor(queue, running);
    parser.start();
    processor.start();
  }

  public static class InputParser extends Thread
  {
    private AtomicBoolean running;
    private Scanner scanner;
    private BlockingQueue<String> queue;

    public InputParser(InputStream in, BlockingQueue<String> queue, AtomicBoolean running)
    {
      super("input-parser-thread");
      scanner = new Scanner(in);
      this.queue = queue;
      this.running = running;
    }

    @Override
    public void run()
    {
      while(running.get())
      {
        String s = scanner.nextLine();
        try
        {
          if(s.equalsIgnoreCase("stop"))
          {
            running.set(false);
          }
          else
          {
            queue.offer(s, 5, TimeUnit.SECONDS);
          }
        }
        catch(InterruptedException e)
        {
          logger.error("Filed to add string to queue", e);
        }
      }
    }
  }

  public static class InputProcessor extends Thread
  {
    private volatile AtomicBoolean running;
    private BlockingQueue<String> queue;

    public InputProcessor(BlockingQueue<String> queue, AtomicBoolean running)
    {
      super("input-processor-thread");
      this.queue = queue;
      this.running = running;
    }

    @Override
    public void run()
    {
      while(running.get())
      {
        try
        {
          String s = queue.poll(5, TimeUnit.SECONDS);
          if(s != null)
          {
            logger.info("Read: " + s);
          }
        }
        catch(InterruptedException e)
        {
          logger.error("Filed to read string from queue", e);
        }
      }
    }
  }
}

--------------------

AndryG

Дата 31.3.2010, 17:16 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Для будущих читателей.
Пост выше - это реализация идеи "читать поток в отдельной нити и через очередь выдавать данные основной нити."

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »