EjecucionThreadEnCore.cs

using System;
using System.Diagnostics;
using System.Threading;

namespace Recetas.Multithreading.Cap01.R0106
{
    public class ManejadorThread
    {
        private bool detenido = false;

        public void Detener()
        {
            detenido = true;
        }

        public void ContarNumeros()
        {
            long contador = 0;

            while (!detenido)
            {
                ++contador;
            }

            Console.WriteLine ("\nEl thread `{0}` con prioridad {1,11} tiene un contador de {2,13}.",
                Thread.CurrentThread.Name,
                Thread.CurrentThread.Priority.ToString(),
                contador.ToString ("N0")
            );
        }
    }

    public sealed class EjecucionThreadEnCore
    {
        public static void EjecutarThreads ()
        {
            ManejadorThread mt = new ManejadorThread();

            // Crea dos instancias de Thread y les
            // asigna un nombre identificativo:
            Thread t1 = new Thread (mt.ContarNumeros);
            t1.Name = "Thread no. 1";
            Thread t2 = new Thread (mt.ContarNumeros);
            t2.Name = "Thread no. 2";

            // Establece el nivel de prioridad:
            t1.Priority = ThreadPriority.Highest;
            t2.Priority = ThreadPriority.Lowest;

            // Inicio de la ejecución de los threads:
            t1.Start ();
            t2.Start ();

            // Detiene el Thread actual por 2 segundos:
            Thread.Sleep (TimeSpan.FromSeconds (2));
            mt.Detener();
        }

        public static void Main()
        {
            Console.WriteLine ("\nPrioridad del thread Main: {0}",
                Thread.CurrentThread.Priority
            );

            Console.WriteLine ("Ejecución sobre todos los núcleos (cores) disponibles...");
            EjecutarThreads();

            // Detiene al thread Main por 2 segundos:
            Thread.Sleep (TimeSpan.FromSeconds (3));
            Console.WriteLine ("\nEjecución sobre un único núcleo (core)...");
            Process.GetCurrentProcess().ProcessorAffinity = new IntPtr (1);
            EjecutarThreads();
        }
    }
}