Вопрос

Я пытаюсь породить тему, чтобы позаботиться о задаче Dowork, которая должна занять менее 3 секунд. Внутри Dowork займет 15 секунд. Я хочу прервать Dowork и перенести контроль обратно в основную нить. Я скопировал код следующим образом, и он не работает. Вместо того, чтобы прервать Dowork, он все еще заканчивает Dowork, а затем передает управление обратно в основную нить. Что я делаю не так?

class Class1
{
    /// <summary>
    /// The main entry point for the application.
    /// </summary>
    /// 

    private static System.Threading.ManualResetEvent[] resetEvents;

    [STAThread]
    static void Main(string[] args)
    {
        resetEvents = new ManualResetEvent[1];

        int i = 0;

        resetEvents[i] = new ManualResetEvent(false);
        ThreadPool.QueueUserWorkItem(new WaitCallback(DoWork),(object)i);


        Thread.CurrentThread.Name = "main thread";

        Console.WriteLine("[{0}] waiting in the main method", Thread.CurrentThread.Name);

        DateTime start = DateTime.Now;
        DateTime end ;
        TimeSpan span = DateTime.Now.Subtract(start);


        //abort dowork method if it takes more than 3 seconds
        //and transfer control to the main thread.
        do
        {
            if (span.Seconds < 3)
                WaitHandle.WaitAll(resetEvents);
            else
                resetEvents[0].Set();


            end = DateTime.Now;
            span = end.Subtract(start);
        }while (span.Seconds < 2);



        Console.WriteLine(span.Seconds);


        Console.WriteLine("[{0}] all done in the main method",Thread.CurrentThread.Name);

        Console.ReadLine();
    }

    static void DoWork(object o)
    {
        int index = (int)o;

        Thread.CurrentThread.Name = "do work thread";

        //simulate heavy duty work.
        Thread.Sleep(15000);

        //work is done..
        resetEvents[index].Set();

        Console.WriteLine("[{0}] do work finished",Thread.CurrentThread.Name);
    }
}
Это было полезно?

Решение

Все Объединенные нити это фоновые потоки, что означает, что они автоматически заканчиваются, когда заканчиваются потоки (ы) приложения.

Я изменил вашу петлю и удалил Resetevents.

     //abort dowork method if it takes more than 3 seconds 
     //and transfer control to the main thread. 
     bool keepwaiting = true;
     while (keepwaiting)
     {
        if (span.Seconds > 3)
        {
           keepwaiting = false;
        }

        end = DateTime.Now;
        span = end.Subtract(start);
     }

Другие советы

[STAThread] это квартира с одной нитью. Пытаться [MTAThread] которая является многоточной квартирой.

Лицензировано под: CC-BY-SA с атрибуция
Не связан с StackOverflow
scroll top