3

Dispatcher を使用してスレッドを作成し、別のスレッドからその Dispatcher を使用して、異なる優先順位で作業をキューに入れたいと考えています。すなわち

var dispatcher = GetNewThreadDispatcher();
dispatcher.BeginInvoke(longRunningTask1, DispatcherPriority.Normal);
dispatcher.BeginInvoke(longRunningTask2, DispatcherPriority.Background);
dispatcher.BeginInvoke(longRunningTask3, DispatcherPriority.Normal);

この場合、バックグラウンド スレッドは を実行しlongRunningTask1、次にlongRunningTask2を実行しlongRunningTask3ます。きれいな を作成するのに苦労していGetNewThreadDispatcher()ます。何か助けはありますか?

4

1 に答える 1

2

新しいバックグラウンド スレッド ( http://msdn.microsoft.com/en-us/library/7a2f3ay4(v=vs.90).aspx ) を作成して取得Dispatcherすることができます。

Dispatcher dispatcher = Dispatcher.FromThread(workerThread);

いくつかの編集: を実行する
Dispatcher dispatcher=Dispatcher.CurrentDispatcherか、Dispatcher.Run内部で実行する必要がありOnThreadStartます。しかし興味深いこと: 実行後

workerThread.Start();
Dispatcher dispatcher = Dispatcher.FromThread(workerThread);

dispatchernull実行後ですが

workerThread.Start();
Console.WriteLine("main thread: Starting worker thread...");
Dispatcher dispatcher = Dispatcher.FromThread(workerThread);

dispatcherいっぱいです

追加した：

    static void OnThreadStart()
    {
       Dispatcher.Run();
    }


    private Dispatcher GetNewThreadDispatcher()
    {
        Thread workerThread=null;
        try
        {
           workerThread = new Thread(OnThreadStart);
           workerThread.IsBackground = true;
           workerThread.Start();
           int waitingCiclesCount = 100;
           int cicleIndex = 0;
           int sleepTimeInMiliseconds = 100;
           Dispatcher dispatcher = null;
           while (cicleIndex < waitingCiclesCount)
           {
               dispatcher = Dispatcher.FromThread(workerThread);
               if (dispatcher!=null)
                   break;
               Thread.Sleep(sleepTimeInMiliseconds);
               cicleIndex = cicleIndex + 1;

           }
           if (dispatcher==null)
           {
               workerThread.Abort();
               return null;
           }
           Console.WriteLine(String.Format("thread with id={0} started", workerThread.ManagedThreadId));
           return dispatcher;
        }
        catch (Exception)
        {
            if (workerThread!=null)
                workerThread.Abort();
            return null;
        }
    }

    public MainWindow()
    {
        InitializeComponent();

        TestWorker worker=new TestWorker();
        Dispatcher dispatcher1 = GetNewThreadDispatcher();
        if(dispatcher1!=null)
            dispatcher1.BeginInvoke(new TestDelegate(worker.DoWork1), DispatcherPriority.Normal);
        else
        {
            MessageBox.Show("Cant create dispatcher1");
        }
        Dispatcher dispatcher2 = GetNewThreadDispatcher();
        if (dispatcher2!=null)
            dispatcher2.BeginInvoke(new TestDelegate(worker.DoWork2), DispatcherPriority.Normal);
        else
        {
            MessageBox.Show("Cant create dispatcher2");
        }
    }

このコードは私のテスト wpf アプリで動作しますが、私はマルチスレッドの専門家ではありません。誰かが私を訂正するか、この返信に情報を追加するかもしれません.

于 2012-12-07T02:01:33.743 に答える