Oczekiwanie określonej liczby sekund na odebranie danych

Question

Wiam.

Problem jest taki. do komunikacji korzystam z klas TcpClient i TcpListener, a informacje przesyłam za pomocą BinaryWriter i BinaryReader. Chciałbym zrobić aby jeżeli będę chciał odebrać jakieś dane a nie przyjdą do 5 sekund to żeby pokazał się komunikat że wystąpił błąd. Niestety BinaryReader posiada tylko metody typu reader.ReadString które blokują wątek do momentu aż danych nie dostaną. Jest jakiś sposób by to obejść?, bo źle przesyła się dane w  gołych bajtach.

Answer 1

Puść to na dwa wątki- jeden niech odlicza, a drugi pobiera informacje. Gdy minie 5 sekund, wyrzucasz stosowny komunikat a oba wątki upierdzielasz.

Comments

Brzmi dobrze ale chcę się upewnić. Jak wykonam metodę abort na wątku który pobiera dane to nie będzie krytycznego błędu ani nie zepsuje socketa? Chciałbym po wywaleniu komunikatu dalej z tego socketa korzystać.

Answer 2

Jakby ktoś potrzebował to macie:

static class RozszerzarkaBinaryReader
{
    static object tmp;
    static bool czyOk;
    static public int domyslneOczekiwanie = 5000;
    public static bool OdbierzString(this BinaryReader br, ref string zm, int milliseconds = -1)
    {
        if (milliseconds == -1)
            milliseconds = domyslneOczekiwanie;
        czyOk = true;
        var odbieranieThread = new Thread(delegate ()
        {
            try
            {
                tmp = br.ReadString();
            }
            catch (Exception)
            {
                czyOk = false;
                return;
            }
        });
        odbieranieThread.Start();

        for (int i = 0; i < milliseconds / 100.0; i++)
        {
            if (!odbieranieThread.IsAlive)
            {
                if (czyOk)
                    zm = (string)tmp;
                return czyOk;
            }
            Thread.Sleep(100);
        }

        odbieranieThread.Abort();

        return false;
    }

    public static bool OdbierzInt32(this BinaryReader br, ref Int32 zm, int milliseconds = -1) //////////////////podmianka
    {
        if (milliseconds == -1)
            milliseconds = domyslneOczekiwanie;
        czyOk = true;
        var odbieranieThread = new Thread(delegate ()
        {
            try
            {
                tmp = br.ReadInt32(); //////////////////podmianka
            }
            catch (Exception)
            {
                czyOk = false;
                return;
            }
        });
        odbieranieThread.Start();

        for (int i = 0; i < milliseconds / 100.0; i++)
        {
            if (!odbieranieThread.IsAlive)
            {
                if (czyOk)
                    zm = (Int32)tmp; //////////////////podmianka
                return czyOk;
            }
            Thread.Sleep(100);
        }

        odbieranieThread.Abort();

        return false;
    }

    public static bool OdbierzBool(this BinaryReader br, ref bool zm, int milliseconds = -1) //////////////////podmianka
    {
        if (milliseconds == -1)
            milliseconds = domyslneOczekiwanie;
        czyOk = true;
        var odbieranieThread = new Thread(delegate ()
        {
            try
            {
                tmp = br.ReadBoolean(); //////////////////podmianka
            }
            catch (Exception)
            {
                czyOk = false;
                return;
            }
        });
        odbieranieThread.Start();

        for (int i = 0; i < milliseconds / 100.0; i++)
        {
            if (!odbieranieThread.IsAlive)
            {
                if (czyOk)
                    zm = (bool)tmp; //////////////////podmianka
                return czyOk;
            }
            Thread.Sleep(100);
        }

        odbieranieThread.Abort();

        return false;
    }

}