Latest web development tutorials

C # Multithreading

Benang didefinisikan sebagai jalur eksekusi program.Setiap thread mendefinisikan aliran unik kontrol. Jika aplikasi Anda melibatkan operasi yang kompleks dan memakan waktu, mengatur jalur eksekusi yang berbeda sering benang berguna, setiap thread melakukan pekerjaan tertentu.

Benang adalahproses ringan.Sebuah contoh umum adalah penggunaan benang dalam pemrograman paralel implementasi sistem operasi modern. Gunakan benang menghemat siklus CPU limbah, sambil meningkatkan efisiensi aplikasi.

Sejauh ini kita telah menyiapkan sebuah program adalah sebuah proses tunggal untuk menjalankan sebagai contoh aplikasi single-threaded sedang berjalan. Namun, dengan aplikasi tersebut hanya dapat melakukan satu tugas pada waktu yang sama. Dalam rangka untuk melakukan banyak tugas secara bersamaan, itu dapat dibagi menjadi benang yang lebih kecil.

Siklus benang Hidup

siklus hidup benang dimulai objek kelas System.Threading.Thread dibuat, akhirnya dihentikan atau diselesaikan di thread eksekusi.

Berikut ini daftar status siklus hidup thread:

  • negara tidak mulai: Ketika contoh benang dibuat, namun metode ini tidak disebut kondisi Start.
  • keadaan siap: siap untuk menjalankan ketika benang menunggu siklus dan kondisi CPU.
  • negara non-operasi: Situasi berikut tidak berjalan di bawah benang:

    • Metode ini telah disebut Sleep
    • Metode ini telah disebut Tunggu
    • Oleh I / O obstruksi operasi
  • Status kematian: Ketika benang memiliki eksekusi selesai atau status dibatalkan saat.

thread utama

Dalam C#, kelas System.Threading.Thread untuk bekerja benang.Hal ini memungkinkan Anda untuk membuat dan mengakses aplikasi multithreaded dalam thread tunggal. Thread pertama dalam proses untuk dieksekusidisebut thread utama.

Ketika program C # dimulai eksekusi, benang utama secara otomatis dibuat. Menggunakan kelasThread untuk membuat thread disebut thread anak thread utama.Anda dapat menggunakan kelas Thread properticurrentThread akses benang.

Program berikut menunjukkan eksekusi thread utama:

menggunakan System;
menggunakan System.Threading;

namespace MultithreadingApplication
{
    kelas MainThreadProgram
    {
        static void Main (string [] args)
        {
            Thread th = Thread.currentThread;
            th.Name = "mainthread";
            Console.WriteLine ( "Ini adalah {0}", th.Name);
            Console.ReadKey ();
        }
    }
}

Ketika kode di atas dikompilasi dan dijalankan, menghasilkan hasil sebagai berikut:

Ini adalah mainthread

kelas Thread atribut umum dan metode

Tabel berikut berisi daftar kelasThread beberapa atribut umum:

属性描述
CurrentContext获取线程正在其中执行的当前上下文。
CurrentCulture获取或设置当前线程的区域性。
CurrentPrinciple获取或设置线程的当前负责人(对基于角色的安全性而言)。
CurrentThread获取当前正在运行的线程。
CurrentUICulture获取或设置资源管理器使用的当前区域性以便在运行时查找区域性特定的资源。
ExecutionContext获取一个 ExecutionContext 对象,该对象包含有关当前线程的各种上下文的信息。
IsAlive获取一个值,该值指示当前线程的执行状态。
IsBackground获取或设置一个值,该值指示某个线程是否为后台线程。
IsThreadPoolThread获取一个值,该值指示线程是否属于托管线程池。
ManagedThreadId获取当前托管线程的唯一标识符。
Name获取或设置线程的名称。
Priority获取或设置一个值,该值指示线程的调度优先级。
ThreadState获取一个值,该值包含当前线程的状态。

Tabel berikut berisi daftar kelasThread beberapa metode yangumumdigunakan:

序号方法名 & 描述
1public void Abort()
在调用此方法的线程上引发 ThreadAbortException,以开始终止此线程的过程。调用此方法通常会终止线程。
2public static LocalDataStoreSlot AllocateDataSlot()
在所有的线程上分配未命名的数据槽。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
3public static LocalDataStoreSlot AllocateNamedDataSlot( string name)
在所有线程上分配已命名的数据槽。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
4public static void BeginCriticalRegion()
通知主机执行将要进入一个代码区域,在该代码区域内线程中止或未经处理的异常的影响可能会危害应用程序域中的其他任务。
5public static void BeginThreadAffinity()
通知主机托管代码将要执行依赖于当前物理操作系统线程的标识的指令。
6public static void EndCriticalRegion()
通知主机执行将要进入一个代码区域,在该代码区域内线程中止或未经处理的异常仅影响当前任务。
7public static void EndThreadAffinity()
通知主机托管代码已执行完依赖于当前物理操作系统线程的标识的指令。
8public static void FreeNamedDataSlot(string name)
为进程中的所有线程消除名称与槽之间的关联。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
9public static Object GetData( LocalDataStoreSlot slot )
在当前线程的当前域中从当前线程上指定的槽中检索值。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
10public static AppDomain GetDomain()
返回当前线程正在其中运行的当前域。
11public static AppDomain GetDomainID()
返回唯一的应用程序域标识符。
12public static LocalDataStoreSlot GetNamedDataSlot( string name )
查找已命名的数据槽。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
13public void Interrupt()
中断处于 WaitSleepJoin 线程状态的线程。
14public void Join()
在继续执行标准的 COM 和 SendMessage 消息泵处理期间,阻塞调用线程,直到某个线程终止为止。此方法有不同的重载形式。
15public static void MemoryBarrier()
按如下方式同步内存存取:执行当前线程的处理器在对指令重新排序时,不能采用先执行 MemoryBarrier 调用之后的内存存取,再执行 MemoryBarrier 调用之前的内存存取的方式。
16public static void ResetAbort()
取消为当前线程请求的 Abort。
17public static void SetData( LocalDataStoreSlot slot, Object data )
在当前正在运行的线程上为此线程的当前域在指定槽中设置数据。为了获得更好的性能,请改用以 ThreadStaticAttribute 属性标记的字段。
18public void Start()
开始一个线程。
19public static void Sleep( int millisecondsTimeout )
让线程暂停一段时间。
20public static void SpinWait( int iterations )
导致线程等待由 iterations 参数定义的时间量。
21public static byte VolatileRead( ref byte address )
public static double VolatileRead( ref double address )
public static int VolatileRead( ref int address )
public static Object VolatileRead( ref Object address )

读取字段值。无论处理器的数目或处理器缓存的状态如何,该值都是由计算机的任何处理器写入的最新值。此方法有不同的重载形式。这里只给出了一些形式。
22public static void VolatileWrite( ref byte address, byte value )
public static void VolatileWrite( ref double address, double value )
public static void VolatileWrite( ref int address, int value )
public static void VolatileWrite( ref Object address, Object value )

立即向字段写入一个值,以使该值对计算机中的所有处理器都可见。此方法有不同的重载形式。这里只给出了一些形式。
23public static bool Yield()
导致调用线程执行准备好在当前处理器上运行的另一个线程。由操作系统选择要执行的线程。

Membuat sebuah thread

Sebuah thread dibuat dengan memperluas kelas Thread. Executive kelas Thread diperpanjang memanggil metodeStart () untuk memulai thread anak.

Program berikut mengilustrasikan konsep ini:

menggunakan System;
menggunakan System.Threading;

namespace MultithreadingApplication
{
    kelas ThreadCreationProgram
    {
        public static void CallToChildThread ()
        {
            Console.WriteLine ( "Anak benang dimulai");
        }
        
        static void Main (string [] args)
        {
            ThreadStart childref = baru ThreadStart (CallToChildThread);
            Console.WriteLine ( "Dalam Main: Membuat thread Anak");
            Thread childThread = new Thread (childref);
            childThread.Start ();
            Console.ReadKey ();
        }
    }
}

Ketika kode di atas dikompilasi dan dijalankan, menghasilkan hasil sebagai berikut:

Di Main: Membuat thread Anak
thread anak mulai

mengelola Thread

kelas Thread menyediakan berbagai metode manajemen.

Contoh berikut menunjukkan penggunaan metodesleep () digunakan dalam thread time-out tertentu.

menggunakan System;
menggunakan System.Threading;

namespace MultithreadingApplication
{
    kelas ThreadCreationProgram
    {
        public static void CallToChildThread ()
        {
            Console.WriteLine ( "Anak benang dimulai");
            // Thread ditangguhkan untuk 5000 milidetik int sleepfor = 5000; 
            Console.WriteLine ( "Anak Thread dijeda untuk {0} detik", 
                              sleepfor / 1000);
            Thread.Sleep (sleepfor);
            Console.WriteLine ( "benang Anak resume");
        }
        
        static void Main (string [] args)
        {
            ThreadStart childref = baru ThreadStart (CallToChildThread);
            Console.WriteLine ( "Dalam Main: Membuat thread Anak");
            Thread childThread = new Thread (childref);
            childThread.Start ();
            Console.ReadKey ();
        }
    }
}

Ketika kode di atas dikompilasi dan dijalankan, menghasilkan hasil sebagai berikut:

Di Main: Membuat thread Anak
thread anak mulai
Anak Thread dijeda selama 5 detik
resume thread anak

menghancurkan benang

Metodebatalkan () digunakan untuk menghancurkan benang.

Dengan melemparkanThreadAbortException batalkan benang pada saat runtime.Pengecualian ini tidak bisa ditangkap, jikaakhirnyablok, kontrol akan dikirimakhirnyablok.

Program berikut menggambarkan hal ini:

menggunakan System;
menggunakan System.Threading;

namespace MultithreadingApplication
{
    kelas ThreadCreationProgram
    {
        public static void CallToChildThread ()
        {
            mencoba
            {

                Console.WriteLine ( "Anak benang dimulai");
                // Hitung sampai 10
                untuk (int counter = 0; kontra <= 10; kontra ++)
                {
                    Thread.Sleep (500);
                    Console.WriteLine (counter);
                }
                Console.WriteLine ( "Anak Thread Tuntas");

            }
            catch (ThreadAbortException e)
            {
                Console.WriteLine ( "Thread Abort Exception");
            }
            akhirnya
            {
                Console.WriteLine ( "Tidak bisa menangkap Thread Exception");
            }

        }
        
        static void Main (string [] args)
        {
            ThreadStart childref = baru ThreadStart (CallToChildThread);
            Console.WriteLine ( "Dalam Main: Membuat thread Anak");
            Thread childThread = new Thread (childref);
            childThread.Start ();
            // Hentikan thread utama untuk beberapa waktu Thread.Sleep (2000);
            // Sekarang ditangguhkan thread anak Console.WriteLine ( "Dalam Main: Membatalkan thread Anak");
            childThread.Abort ();
            Console.ReadKey ();
        }
    }
}

Ketika kode di atas dikompilasi dan dijalankan, menghasilkan hasil sebagai berikut:

Di Main: Membuat thread Anak
thread anak mulai
0
1
2
Di Main: Membatalkan benang Anak
Thread Abort Exception
tidak bisa menangkap Exception Thread