[es] - Čitanje sa network streama u petlji bez blokiranja

blaza985
student

Član broj: 263445
Poruke: 2
95.180.82.*

Profil

Čitanje sa network streama u petlji bez blokiranja

^{01.07.2010. u 11:29 - pre 168 meseci}

Pozdrav. Imam jedan problem koji ne uspevam da rešim. Naime, u jednom delu programa je potrebno da u petlji čitam sa network streama, ali tako da ne dodje do blokiranja petlje usled čekanja da podaci pristignu od strane klijenta. Pokušao sam da uradim to na nekoliko načina, ali ne uspeva. Za početak da napišem prvo code:

Code:

            NetworkStream stream = new NetworkStream(socket);
            StreamReader reader = new StreamReader(stream);
            BinaryFormatter formatter = new BinaryFormatter();
            StreamWriter writer = new StreamWriter(stream);

            string msg = reader.ReadLine();

            while (msg != "END")
            {

                switch (msg)
                {

                    case "WRITE":
                        {
                            Write();
                            break;
                        }
                    case "RETURN":
                        {
                            ReturnRecord();
                            break;
                        }
                    case "FIND":
                        {
                            FindRecord();
                            break;
                        }
                    default:
                        break;
                }

                if (stream.DataAvailable)
                {
                    msg = reader.ReadLine();

                }
                else
                {
                    msg = "";
                }

            }

E sad, umesto sledećeg dela code-a:

Code:

                if (stream.DataAvailable)
                {
                    msg = reader.ReadLine();

                }
                else
                {
                    msg = "";
                }

pokušao sam na još par načina, između ostalog i sa:

Code:

                if (reader.Peek() != -1)
                {
                    msg = reader.ReadLine();
                }
                else
                {
                    msg = "";
                }

Dakle, bitno mi je da u samoj petlji ne dodje do blokiranja pri pozivu Readline metode. Kod mene pri korišćenju nekog od prethodnih načina program upada u beskonačnu petlju jer reader.Peek() uvek vraća -1, iako su podaci sa klijenta poslati. Slično se dešava i korišćenjem stream.DataAvailable. U funkcijama Write(), ReturnRecord() i FindRecord() koristim BinaryFormatter za deserijalizaciju sa streama, i izgleda da zbog toga dolazi do problema, jer čim se program vrati iz neke od tih funkcija (gde je vršio deserijalizaciju na streamu) reader.Peek uvek vraća -1 iako su podaci sa klijenta poslati.
Ako uklonim iz programa uslov if(reader.Peek != -1), program radi kako treba, ali dolazi do blokiranja u petlji koje želim da izbegnem. Nije mi jasno zašto se Peek() pogubi nakon korišćenja deserijalizacije.

Jel ima neko ideju kako bih ovo mogao da rešim?

Odgovor na temu