Можно ли реорганизовать этот EventWaitHandle, чтобы не использовать Thread.Sleep () для управления состоянием гонки? - PullRequest
Новая
       0

Можно ли реорганизовать этот EventWaitHandle, чтобы не использовать Thread.Sleep () для управления состоянием гонки?

0 голосов
/ 18 февраля 2012

Я хочу отправить сообщение с сервера всем клиентам.Есть 0- * клиентов.Сервер может работать, а может и не работать, когда клиент загружен.Функциональность здесь работает так, как я хочу.Я пытаюсь выяснить, можно ли это сделать без Thread.Sleep()?Также обратите внимание, что клиенты и сервер находятся в независимых процессах.

Часть сервера 

class NamedEventsServer
{
    internal static void Main()
    {
        const string ewhName = "StickyNoteEwh";

        EventWaitHandle ewh = null;
        bool doesNotExist = false;
        bool wasCreated;

        // Attempt to open the named event.
        try
        {
            ewh = EventWaitHandle.OpenExisting(ewhName);
        }
        catch (WaitHandleCannotBeOpenedException)
        {
            Console.WriteLine("Named event does not exist.");
            doesNotExist = true;
        }
        if (doesNotExist)
        {
            // The event does not exist, so create it.

            ewh = new EventWaitHandle(true,
                EventResetMode.ManualReset,
                ewhName,
                out wasCreated);

            if (wasCreated)
            {
                Console.WriteLine("Created the named event.");
            }
            else
            {
                Console.WriteLine("Unable to create the event.");
                return;
            }
        }
        ewh.Set();
        Thread.Sleep(1000);//wait one second...giving threads enough time to all respond.  Then stop triggering the event.
        ewh.Reset();

        //exit
    }
}

Клиентская часть 

class NamedEventsClient
{
    internal static void Main()
    {
        const string ewhName = "StickyNoteEwh";

        while (true)
        {
            EventWaitHandle ewh = null;
            bool doesNotExist = false;
            bool wasCreated;
            // Attempt to open the named event.
            try
            {
                ewh = EventWaitHandle.OpenExisting(ewhName);
            }
            catch (WaitHandleCannotBeOpenedException)
            {
                Console.WriteLine("Named event does not exist.");
                doesNotExist = true;
            }
            if (doesNotExist)
            {
                // The event does not exist, so create it.

                ewh = new EventWaitHandle(false,
                    EventResetMode.ManualReset,
                    ewhName,
                    out wasCreated);

                if (wasCreated)
                {
                    Console.WriteLine("Created the named event.");
                }
                else
                {
                    Console.WriteLine("Unable to create the event.");
                    return;
                }
            }
            Console.WriteLine("Wait on the event.");
            ewh.WaitOne();
            Console.WriteLine("Event was signaled.");
            //Console.WriteLine("Press the Enter key exit.");
            Thread.Sleep(1000);
            //Console.ReadLine();
        }
    }
}

1 Ответ

0 голосов
/ 18 февраля 2012

Я полагаю, это зависит от того, уверены ли вы, что все клиенты получат свой временной интервал в течение секунды. Это звучит разумно, но в условиях чрезвычайного стресса некоторые клиенты могут его пропустить. Насколько это важно?

Во всяком случае, я думаю, что это именно то, для чего вы должны использовать ZeroMQ. Он легкий и позаботится обо всех потенциальных ошибках для вас.

...