Aracılığıyla paylaş

İş parçacıklarını zamanlama

Her iş parçacığına bir iş parçacığı önceliği atanır. Ortak dil çalışma zamanı içinde oluşturulan iş parçacıklarına başlangıçta ThreadPriority.Normal önceliği verilir. Çalışma zamanı dışında oluşturulan iş parçacıkları, yönetilen ortama girmeden önce sahip oldukları önceliği korur. özelliğiyle Thread.Priority herhangi bir iş parçacığının önceliğini alabilir veya ayarlayabilirsiniz.

İş parçacıkları, önceliklerine göre yürütülmeye programlanır. İş parçacıkları çalışma zamanı içinde yürütülse de, tüm iş parçacıklarına işletim sistemi tarafından işlemci zaman dilimleri atanır. İş parçacıklarının yürütüleceği sırayı belirlemek için kullanılan zamanlama algoritmasının ayrıntıları her işletim sistemine göre değişir. Bazı işletim sistemlerinde, en yüksek önceliğe sahip iş parçacığı (yürütülebilen iş parçacıklarından) her zaman önce çalışacak şekilde zamanlanır. Aynı önceliğe sahip birden çok iş parçacığının tümü kullanılabilir durumdaysa, zamanlayıcı iş parçacıkları arasında bu önceliğe göre döngü gerçekleştirerek her iş parçacığına yürütülecek sabit bir zaman dilimi verir. Daha yüksek önceliğe sahip bir iş parçacığı çalıştırılabileceği sürece, düşük öncelikli iş parçacıkları çalıştırılmaz. Belirli bir önceliğe sahip daha fazla çalışabilen iş parçacığı olmadığında, zamanlayıcı bir sonraki düşük önceliğe geçer ve bu öncelikteki iş parçacıklarını yürütme için planlar. Daha yüksek öncelikli bir iş parçacığı çalıştırılabilir hale gelirse, düşük öncelikli iş parçacığı önlenir ve daha yüksek öncelikli iş parçacığının bir kez daha yürütülmesine izin verilir. Tüm bunların yanı sıra, bir uygulamanın kullanıcı arabirimi ön plan ve arka plan arasında taşındığından işletim sistemi iş parçacığı önceliklerini dinamik olarak da ayarlayabilir. Diğer işletim sistemleri farklı bir zamanlama algoritması kullanmayı seçebilir.

Örnek

Thread.Priority numaralandırmasından, tüm 5 öncelik seviyesi boyunca yürütülen 9 iş parçacığı örneği sunulmuştur. En yüksek öncelik düzeyinde ise son 5 iş parçacığı bulunmaktadır. Ayrıca, önceki makaleden aldığımız geri çağırma desteği, bu bağlamda iş parçacığı başlatma ve öncelik belirleme sırasının her zaman sonraki koda veya işlem yürütme sırasına yansıtılmayacağını göstermektedir. Yani burada kod yürütmenin paralel niteliğini ve her iş parçacığı için işletim sistemi tarafından atanan işlemci zamanı dilimlerinin gösterimini görüyoruz. Bu, iş parçacıklarının çalıştığı ortamın etkisini ve denetimini vurgular. Bununla birlikte, en yüksek öncelikli iş parçacıklarının yürütmede gerçekten öncelik aldığını kesinlikle görüyoruz.

Aşağıdaki kod her yürütmede rastgele sonuçlar üretir. Ancak, kodu birden çok kez çalıştırdıktan ve çıkışlar çözümlendikten sonra çalıştırılan önceliklerin ortak sıra desenleri gözlemlenebilir.

namespace snippets;

public class SchedulingThreads
{
    public void RunMultipleThreadsOnDifferentPriorities()
    {
        var threadsList = new List<Thread>(9);

        // Initialize 9 threads. 5 with Highest priority, and the first 4 from Lowest to Normal range.
        for (int i = 0; i < 9; i++)
        {
            var thread = new Thread(() => { new ThreadWithCallback(Callback).Process(); });

            if (i > 3)
                thread.Priority = ThreadPriority.Highest;
            else
                thread.Priority = (ThreadPriority)i;

            threadsList.Add(thread);
        }

        threadsList.ForEach(thread => thread.Start());
    }

    public void Callback(ThreadPriority threadPriority)
    {
        Console.WriteLine($"Callback in {threadPriority} priority. \t\t ThreadId: {Thread.CurrentThread.ManagedThreadId}.");
    }

    public class ThreadWithCallback
    {
        public ThreadWithCallback(Action<ThreadPriority> callback)
        {
            this.callback = callback;
        }

        public Action<ThreadPriority> callback;

        public void Process()
        {
            Console.WriteLine($"Entered process in {Thread.CurrentThread.Priority} priority.  \t\t ThreadId: {Thread.CurrentThread.ManagedThreadId}.");
            Thread.Sleep(1000);
            Console.WriteLine($"Finished process in {Thread.CurrentThread.Priority} priority. \t\t ThreadId: {Thread.CurrentThread.ManagedThreadId}.");

            if (callback != null)
            {
                callback(Thread.CurrentThread.Priority);
            }
        }
    }

    // The example displays the output like the following:
    //      Entered process in Highest priority.             ThreadId: 9.
    //      Entered process in Highest priority.             ThreadId: 12.
    //      Entered process in Normal priority.              ThreadId: 6.
    //      Entered process in BelowNormal priority.         ThreadId: 5.
    //      Entered process in Lowest priority.              ThreadId: 4.
    //      Entered process in AboveNormal priority.         ThreadId: 7.
    //      Entered process in Highest priority.             ThreadId: 11.
    //      Entered process in Highest priority.             ThreadId: 10.
    //      Entered process in Highest priority.             ThreadId: 8.
    //      Finished process in Highest priority.            ThreadId: 9.
    //      Finished process in Highest priority.            ThreadId: 12.
    //      Finished process in Highest priority.            ThreadId: 8.
    //      Finished process in Highest priority.            ThreadId: 10.
    //      Callback in Highest priority.                    ThreadId: 10.
    //      Finished process in AboveNormal priority.        ThreadId: 7.
    //      Callback in AboveNormal priority.                ThreadId: 7.
    //      Finished process in Lowest priority.             ThreadId: 4.
    //      Callback in Lowest priority.                     ThreadId: 4.
    //      Finished process in Normal priority.             ThreadId: 6.
    //      Callback in Highest priority.                    ThreadId: 9.
    //      Callback in Highest priority.                    ThreadId: 8.
    //      Callback in Highest priority.                    ThreadId: 12.
    //      Finished process in Highest priority.            ThreadId: 11.
    //      Callback in Highest priority.                    ThreadId: 11.
    //      Callback in Normal priority.                     ThreadId: 6.
    //      Finished process in BelowNormal priority.        ThreadId: 5.
    //      Callback in BelowNormal priority.                ThreadId: 5.
}

Ayrıca bkz.

  • Last updated on