Есть такой код:

stream.ReadTimeout = 1000;
IAsyncResult result = stream.BeginRead(BufferIn, 0, 1, null, stream); (1)
result.AsyncWaitHandle.WaitOne(1000); (2)
stream.EndRead(result); (3)

Из stream должны поступить байты, но могут и не поступить. Если байты не поступают, то на (3) программа зависает на очень долго.
Я понимаю что EndRead ждет завершения асинхронной операции. Но после 1000 мс данные мне уже не актуальны.
MSDN говорить что нужно после BeginRead обязательно использовать EndRead. Как сделать чтобы (3) не зависало?

Здравствуйте, SATANAblack, Вы писали:

AFAIK такое не уровне WinAPI не возможно, так что...

Здравствуйте, SATANAblack, Вы писали:

SAT>Я понимаю что EndRead ждет завершения асинхронной операции. Но после 1000 мс данные мне уже не актуальны.
SAT>MSDN говорить что нужно после BeginRead обязательно использовать EndRead. Как сделать чтобы (3) не зависало?
В BeginRead указать AsyncCallback, в котором вызывать EndRead, и если данные не нужны — то выбрасывать их.

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

A>AFAIK такое не уровне WinAPI не возможно, так что...

Ну а если сделать так?

stream.ReadTimeout = 1000;
result = stream.BeginRead(BufferIn, 0, 1, null, stream);
if(result.AsyncWaitHandle.WaitOne(1000))
   stream.EndRead(result);

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

Здравствуйте, SATANAblack, Вы писали:

SAT>Ну а если сделать так?

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

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

SAT>>Ну а если сделать так?

A>Ресурсы будут течь. Лучше всего дождаться данных, а уже потом проверять сколько времени прошло.

Программа используется для чтения/записи контроллера, через интерфейс COM/TCP. Если данных нет 1-2 сек, то нужно снова слать новый запрос.

Здравствуйте, SATANAblack, Вы писали:

SAT>Если данных нет 1-2 сек, то нужно снова слать новый запрос.

А в старом запросе приходит ноль байт?

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

SAT>>Если данных нет 1-2 сек, то нужно снова слать новый запрос.

A>А в старом запросе приходит ноль байт?

Сначала я: BeginWrite...EndWrite — все хорошо, я отправил запрос
Потом: BeginRead ....EndRead — контроллер просто не ответил, вообще ничего.

Здравствуйте, SATANAblack, Вы писали:

SAT>Сначала я: BeginWrite...EndWrite — все хорошо, я отправил запрос
SAT>Потом: BeginRead ....EndRead — контроллер просто не ответил, вообще ничего.

Когда вы дожидаетесь завершения EndRead данные от контроллёра приходят или нет?

Вы сейчас описываете следующую ситуацию (в хронологическом порядке)

BeginRead1
прошла секунда секунду
BeginRead2
EndRead2 (получили данные)
EndRead1 (пустой ответ)

Полный алгоритм общения должен быть такой:

1)BeginWrite(Запрос1)
2)Ответ1=BeginRead()
3)if(Ответ1==0) goto 1)

4)BeginWrite(Запрос2)
5)Ответ2=BeginRead()
6)if(Ответ2==0) goto 4)

Короче, запрашиваем пока не ответят. Но если не ответили BeginRead() остается ждать ответа.

Здравствуйте, SATANAblack, Вы писали:

SAT>Короче, запрашиваем пока не ответят. Но если не ответили BeginRead() остается ждать ответа.

Ну и ждите, в чём проблема вообще не ясно.

A>Когда вы дожидаетесь завершения EndRead данные от контроллёра приходят или нет?
A>Вы сейчас описываете следующую ситуацию (в хронологическом порядке)
A>BeginRead1
A>прошла секунда секунду
A>BeginRead2
A>EndRead2 (получили данные)
A>EndRead1 (пустой ответ)

Нет, я такого не описываю.
У меня должен быть на каждый запрос — ответ.
Если ответа нет повторить запрос.
Если ответа нет повторить запрос еще.
Если снова ответа нет — заканчиваем всё.

Здравствуйте, SATANAblack, Вы писали:

SAT>Нет, я такого не описываю.
SAT>У меня должен быть на каждый запрос — ответ.
SAT>Если ответа нет повторить запрос.
SAT>Если ответа нет повторить запрос еще.
SAT>Если снова ответа нет — заканчиваем всё.

Лучшее что вы можете сделать, анализировать время между Begin и End в AsyncCallback.

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

SAT>>Короче, запрашиваем пока не ответят. Но если не ответили BeginRead() остается ждать ответа.

A>Ну и ждите, в чём проблема вообще не ясно.

Проблема в том что не надо мне ждать больше 1 сек.

Здравствуйте, SATANAblack, Вы писали:

A>>Ну и ждите, в чём проблема вообще не ясно.
SAT>Проблема в том что не надо мне ждать больше 1 сек.

Ждите сколько получится и уже когда дождались проверяйте сколько ждали.

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

SAT>>Нет, я такого не описываю.
SAT>>У меня должен быть на каждый запрос — ответ.
SAT>>Если ответа нет повторить запрос.
SAT>>Если ответа нет повторить запрос еще.
SAT>>Если снова ответа нет — заканчиваем всё.

A>Лучшее что вы можете сделать, анализировать время между Begin и End в AsyncCallback.

Ну...и...вот ето я и спрашиваю. Анализирую...прошла 1 секунда....что делать дальше? Как разумно продолжить выполнение программы?
Ну припустим вывести сообщение про то сколько принято байт.0,10,500...

Здравствуйте, SATANAblack, Вы писали:

A>>Лучшее что вы можете сделать, анализировать время между Begin и End в AsyncCallback.

SAT>Ну...и...вот ето я и спрашиваю. Анализирую...прошла 1 секунда....что делать дальше? Как разумно продолжить выполнение программы?

анализировать время между Begin и End в AsyncCallback.

Здравствуйте, adontz, Вы писали:

A>Здравствуйте, SATANAblack, Вы писали:

A>>>Лучшее что вы можете сделать, анализировать время между Begin и End в AsyncCallback.

SAT>>Ну...и...вот ето я и спрашиваю. Анализирую...прошла 1 секунда....что делать дальше? Как разумно продолжить выполнение программы?

A>анализировать время между Begin и End в AsyncCallback.

Проанализировал, решил что даных уже не будет. Как продолжить работу?

Здравствуйте, SATANAblack, Вы писали:

SAT>Проанализировал, решил что даных уже не будет. Как продолжить работу?

Решать продолжать ли работу вам надо в другом потоке. В AsyncCallback вы анализируете время, вызываете EndRead, изменяете внутренее состояние. Вам надо после BeginRead зафиксировать момент времени и начать раз в 100мс, например, проверять пришёл ли ответ (это вы из AsyncCallback будете указывать), и если не пришёл то повторять запрос снова.