ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / Как передавать данные между потоками(threads) ?
25 сообщений из 30, страница 1 из 2
  1  все
Как передавать данные между потоками(threads) ?
    #38683232
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
Читая про I/O не без удивления заметил, что для этой цели рекомендуется использовать
PipedInputStream/PipedOutputStream.

Поясните, что они такого особого предоставляют ?

Также в меня вседяются опасения после таких формацлировок в javadoc:
http://docs.oracle.com/javase/7/docs/api/java/io/PipedInputStream.html Attempting to use both objects from a single thread is not recommended, as it may deadlock the thread


Почему просто не сделать какой-то объект, который виден вовлеченным в процесс потоками и записывать в него данные, соблюдая правила happens-before?

Что-то в моей логике явно криво. Помогите разобраться.
...
Рейтинг: 0 / 0
29.06.2014, 23:52
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683233
DEVcoach
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
DEVcoach
Гость
questioner ,
Опишите задачу, которую вы решаете. В конкурентной разработке эти пайпы - экзотика. Расшарили переменную между потоками, и вперед.
...
Рейтинг: 0 / 0
29.06.2014, 23:55
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683235
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
DEVcoach,

никакой конкретной проблемы не решаю. Улучшаю свои знания в java se.
...
Рейтинг: 0 / 0
29.06.2014, 23:56
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683237
DEVcoach
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
DEVcoach
Гость
redwhite90DEVcoach,
никакой конкретной проблемы не решаю. Улучшаю свои знания в java se.Понятно, тогда можете смело забить на эти пайпы :-)
...
Рейтинг: 0 / 0
30.06.2014, 00:03
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683244
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
DEVcoachredwhite90DEVcoach,
никакой конкретной проблемы не решаю. Улучшаю свои знания в java se.Понятно, тогда можете смело забить на эти пайпы :-)

а тут слово "эти" несёт какую-то смысловую нагрузку? ну всмысле ещё какие-то пайпы есть?
...
Рейтинг: 0 / 0
30.06.2014, 00:17
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683254
Фотография mayton
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
mayton
Участник
questioner, вот тут про пайпы доходчиво и сердито

http://tutorials.jenkov.com/java-nio/pipe.html

Кажется больше и добавить нечего.
...
Рейтинг: 0 / 0
30.06.2014, 00:57
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683256
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
mayton,

хм, а нафига одно и то же в IO и в NIO ?
...
Рейтинг: 0 / 0
30.06.2014, 01:01
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683259
Фотография mayton
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
mayton
Участник
Почему одно и тоже?
...
Рейтинг: 0 / 0
30.06.2014, 01:10
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683261
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
mayton,

по картинке сужу, но я в этой теме совсем плох, поэтому хотелось бы разъяснений.
...
Рейтинг: 0 / 0
30.06.2014, 01:14
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683275
Basil A. Sidorov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Basil A. Sidorov
Участник
questionerТакже в меня вседяются опасения после таких формацлировок в javadoc:
http://docs.oracle.com/javase/7/docs/api/java/io/PipedInputStream.html Attempting to use both objects from a single thread is not recommended, as it may deadlock the threadПророки предупреждают, что если в вы сделаете чтение из PipedOutputStream, но при этом другая часть ваша вашего кода в этом же потоке (ещё) ничего не записала в PipedInputStream - будет классическая блокировка.
...
Рейтинг: 0 / 0
30.06.2014, 02:14
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683358
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
questionerЧитая про I/O не без удивления заметил, что для этой цели рекомендуется использовать
PipedInputStream/PipedOutputStream.
Подозреваю что исходное утверждение сильно отличается от того что написано здесь. Никто не рекомендует передавать данные между потоками используя Piped Stream. Вы что-то читаете, про Piped Stream. Но это совершенно не обозначает что оно решает задачу передачит данных между потоками для всех случаев жизни.


questioner
Также в меня вседяются опасения после таких формацлировок в javadoc:
http://docs.oracle.com/javase/7/docs/api/java/io/PipedInputStream.html Attempting to use both objects from a single thread is not recommended, as it may deadlock the thread

Это ключевой момент для понимания Piped Stream.

questionerПочему просто не сделать какой-то объект, который виден вовлеченным в процесс потоками и записывать в него данные, соблюдая правила happens-before?

Потому что речь про IO и про Stream, а не про обмен данными между потоками вообще.

questionerЧто-то в моей логике явно криво. Помогите разобраться.
Логика примерно такая же как при испольховании класса Process. Вы с ним разбирались уже? Когда процесс пишет что-то в out, то ваш Java код, должен это вычитывать. Иначе процесс заблокируется на IO. Так и здесь. Один поток пишет stream, второй читает. Как только один из них перестаёт читать или писать, то второй заблокируется, пытаясь сделать обратную операцию.

Можно представить двух человек на ковеере. Один передаёт другому кирпичи. Если передающий займентся чем-то другим, то принимающий будет его ждать. Но не сможет ничего делать. Ведь в любой момент может прилететь кирпич от передающего.
И аналогично в обратную сторону. Если принимающий займется чем-то другим, то передающий застопорится с кирпичом в руках. Ни положить. Ни отдать. Только interrupt :)
...
Рейтинг: 0 / 0
30.06.2014, 09:31
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683384
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
Basil A. SidorovquestionerТакже в меня вседяются опасения после таких формацлировок в javadoc:
пропущено...
Пророки предупреждают, что если в вы сделаете чтение из PipedOutputStream, но при этом другая часть ваша вашего кода в этом же потоке (ещё) ничего не записала в PipedInputStream - будет классическая блокировка.

А в чем принципиальная разница в один поток это всё делается или в несколько?

Для меня классический deadlock это с двумя синхронайзами в разном порядке.
...
Рейтинг: 0 / 0
30.06.2014, 10:05
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683391
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
Blazkowicz,
авторМожно представить двух человек на ковеере. Один передаёт другому кирпичи. Если передающий займентся чем-то другим, то принимающий будет его ждать. Но не сможет ничего делать. Ведь в любой момент может прилететь кирпич от передающего.
И аналогично в обратную сторону. Если принимающий займется чем-то другим, то передающий застопорится с кирпичом в руках. Ни положить. Ни отдать. Только interrupt :)

теперь понятно)

Это как в ArrayBlockingQueue например
...
Рейтинг: 0 / 0
30.06.2014, 10:12
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683393
questioner
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
questioner
Гость
BlazkowiczquestionerЧитая про I/O не без удивления заметил, что для этой цели рекомендуется использовать
PipedInputStream/PipedOutputStream.
Подозреваю что исходное утверждение сильно отличается от того что написано здесь. Никто не рекомендует передавать данные между потоками используя Piped Stream. Вы что-то читаете, про Piped Stream. Но это совершенно не обозначает что оно решает задачу передачит данных между потоками для всех случаев жизни.


questioner
Также в меня вседяются опасения после таких формацлировок в javadoc:
пропущено...


Это ключевой момент для понимания Piped Stream.

questionerПочему просто не сделать какой-то объект, который виден вовлеченным в процесс потоками и записывать в него данные, соблюдая правила happens-before?

Потому что речь про IO и про Stream, а не про обмен данными между потоками вообще.




Ок, общественное мнение говорит, что про пайпы стоит знать только то, что они существуют)
...
Рейтинг: 0 / 0
30.06.2014, 10:14
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683399
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
questionerА в чем принципиальная разница в один поток это всё делается или в несколько?

В том что в один поток оно не делает в принципе.
...
Рейтинг: 0 / 0
30.06.2014, 10:17
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683403
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
questionerОк, общественное мнение говорит, что про пайпы стоит знать только то, что они существуют)
Именно. На практике применяется довольно редко.
...
Рейтинг: 0 / 0
30.06.2014, 10:18
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683421
Basil A. Sidorov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Basil A. Sidorov
Участник
questionerА в чем принципиальная разница в один поток это всё делается или в несколько?Это как разница между последовательным и параллельным соединением
...
Рейтинг: 0 / 0
30.06.2014, 10:30
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683569
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
У меня ещё один вброс на эту тему)

Тут уже проскользнуло в обсуждении что пайпы бывают в io и в nio. Наша беседа шла про io в основном. Как выяснилось, существует проблема блокировки.

а nio ? ее же вроде как позиционируют как неблокируюшее сушество ? получается в ней нет этой проблемы?
...
Рейтинг: 0 / 0
30.06.2014, 12:17
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683579
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
redwhite90У меня ещё один вброс на эту тему)
Тут уже проскользнуло в обсуждении что пайпы бывают в io и в nio. Наша беседа шла про io в основном. Как выяснилось, существует проблема блокировки.
а nio ? ее же вроде как позиционируют как неблокируюшее сушество ? получается в ней нет этой проблемы?
JavaDoc лениво ковырять. Но, на сколько я понимаю, все те же самые фишки что и в NIO. Блокирующий\неблокирующий режимы. Блокирующий работает как в IO. Неблокирующий, просто выйдет из метода, сообщив что ничего не записано или не прочитано.
...
Рейтинг: 0 / 0
30.06.2014, 12:24
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683667
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
Blazkowicz,

кстати это дедлок?

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
        PipedInputStream pipedInputStream = new PipedInputStream();
        PipedOutputStream pipedOutputStream = new PipedOutputStream();
        pipedOutputStream.connect(pipedInputStream);


        ObjectOutputStream objectOutputStream = new ObjectOutputStream(pipedOutputStream);
        ObjectOutputStream objectOutputStreamWrapper = new ObjectOutputStream(objectOutputStream);     //double wrapping

        objectOutputStreamWrapper.writeObject("this is my string");

        ObjectInputStream objectInputStream = new ObjectInputStream(pipedInputStream);
        ObjectInputStream   objectInputStreamWrapper = new ObjectInputStream(objectInputStream);

        System.out.println(objectInputStreamWrapper.readObject());




P.S. если дважды не оборачивать - всё работает.
...
Рейтинг: 0 / 0
30.06.2014, 13:28
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683671
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Там буфер на 1024.
...
Рейтинг: 0 / 0
30.06.2014, 13:31
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683674
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
BlazkowiczТам буфер на 1024.

буфер чего?

как влияет двойное оборачивание?
...
Рейтинг: 0 / 0
30.06.2014, 13:33
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683679
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
redwhite90буфер чего?

Буфер байт. Чего же ещё? До его переполнения, вероятно, не блокируется.

redwhite90как влияет двойное оборачивание?
Это у тебя что-то сродни double penetration? В извращениях ковыряться желания не имею.
...
Рейтинг: 0 / 0
30.06.2014, 13:37
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683704
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
Blazkowiczredwhite90буфер чего?

Буфер байт. Чего же ещё? До его переполнения, вероятно, не блокируется.

Из ответа понял, что буфер пайпа)

redwhite90как влияет двойное оборачивание?
Это у тебя что-то сродни double penetration? В извращениях ковыряться желания не имею.[/quot]

согласен, извращение, но я предположил, что если пойму как это работает - пойму как декоратор I/O работает
...
Рейтинг: 0 / 0
30.06.2014, 13:59
| Ответить | Цитировать | Написать  
Как передавать данные между потоками(threads) ?
    #38683983
redwhite90
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
redwhite90
Гость
Blazkowicz,

оказалось, что дело во флаше.
...
Рейтинг: 0 / 0
30.06.2014, 17:22
| Ответить | Цитировать | Написать  
25 сообщений из 30, страница 1 из 2
  1  все
Форумы / Java [игнор отключен] [закрыт для гостей] / Как передавать данные между потоками(threads) ?
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=59&fpage=169&tid=2126963]:
 0ms
get settings:
 5ms
get forum list:
 12ms
check forum access:
 2ms
check topic access:
 2ms
track hit:
 47ms
get topic data:
 9ms
get forum data:
 2ms
get page messages:
 52ms
get tp. blocked users:
 1ms
others: 206ms
total:  338ms
созд. / загр.: 338ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]