Làm thế nào để bạn xác định xem các chủ đề con đã hoàn thành

Question

Tôi đang sử dụng nhiều luồng trong ứng dụng của tôi bằng cách sử dụng vòng lặp (true) và bây giờ tôi muốn thoát khỏi vòng lặp khi tất cả các chủ đề đang hoạt động hoàn thành công việc của họ.

Answer 1

Bạn có thể sử dụng Process.GetCurrentProcess(). Threads.Count.

Answer 2

Có cách tiếp cận khác nhau ở đây, nhưng utlimately nhất trong số họ đi xuống để thay đổi đề thi của bạn để làm một cái gì đó bất cứ khi nào họ rời khỏi (thành công hay qua ngoại lệ, mà bạn không muốn làm anyway). Một cách tiếp cận đơn giản có thể là sử dụng Interlock.Decrement để giảm số lượt truy cập - và nếu đó là số không (hoặc -ve, có thể là lỗi), hãy giải phóng một đối tượng ManualResetEvent hoặc Monitor.Pulse; trong cả hai trường hợp, chủ đề gốc sẽ đợi trên đối tượng đó. Một số cách tiếp cận như vậy là discussed here.

Tất nhiên, có thể dễ dàng xem xét các bit TPL trong 4.0, cung cấp nhiều tùy chọn mới ở đây (không phải những thứ như Parallel.For trong PLINQ).

Nếu bạn đang sử dụng hàng đợi công việc đã đồng bộ hóa, bạn cũng có thể đặt hàng đợi đó để đóng (thoát) chính nó và chỉ cần đợi hàng đợi trống? Giả định ở đây là các chuỗi công nhân của bạn đang làm một việc gì đó như:

T workItem; 
while(queue.TryDequeue(out workItem)) { // this may block until either something 
    ProcessWorkItem(workItem);   // todo, or the queue is terminated 
} 
// queue has closed - exit the thread 

trong trường hợp này, hàng đợi trống rỗng, tất cả các chuỗi công nhân của bạn phải đang trong quá trình tự sát.

Answer 3

Giả sử rằng bạn có danh sách các chủ đề, đây là hai cách tiếp cận.

Giải pháp đầu tiên:

Sử dụng Thread.Join() với một tham số khoảng thời gian để đồng bộ với mỗi chủ đề lần lượt. Giá trị trả lại cho bạn biết liệu luồng đã kết thúc hay chưa.

Giải pháp thứ hai:

Kiểm tra Thread.IsAlive() để xem các chủ đề vẫn chạy.

Trong cả hai trường hợp, đảm bảo rằng chuỗi chính của bạn mang lại thời gian xử lý cho các chuỗi đang chạy, vòng lặp chờ của bạn sẽ tiêu thụ hầu hết/tất cả CPU và làm hỏng luồng công nhân của bạn.

Answer 4

Bạn có thể sử dụng Thread.Join(). Phương thức Join sẽ chặn chuỗi gọi cho đến khi chuỗi (phương thức mà phương thức Join được gọi) chấm dứt.

Vì vậy, nếu bạn có danh sách chuỗi, bạn có thể lặp lại và gọi Join trên mỗi chuỗi. Bạn vòng lặp sẽ chỉ thoát khi tất cả các chủ đề đã chết. Một cái gì đó như thế này:

for(int i = 0 ;i < childThreadList.Count; i++) 
{ 
    childThreadList[i].Join(); 
} 
///...The following code will execute when all threads in the list have been terminated.../// 

Answer 5

Tôi thấy rằng việc sử dụng phương thức Join() là cách sạch nhất. Tôi sử dụng nhiều chủ đề thường xuyên, và mỗi luồng thường tải dữ liệu từ các nguồn dữ liệu khác nhau (Informix, Oracle và SQL cùng một lúc.) Một vòng lặp đơn giản, như đã đề cập ở trên, gọi Join() trên mỗi đối tượng thread (mà tôi lưu trữ một đối tượng List đơn giản) hoạt động !!!

Carlos Merighe.

Answer 6

Tôi thích sử dụng một HashSet of Threads:

// create a HashSet of heavy tasks (threads) to run 
HashSet<Thread> Threadlist = new HashSet<Thread>(); 
Threadlist.Add(new Thread(() => SomeHeavyTask1())); 
Threadlist.Add(new Thread(() => SomeHeavyTask2())); 
Threadlist.Add(new Thread(() => SomeHeavyTask3())); 

// start the threads 
foreach (Thread T in Threadlist) 
    T.Start(); 

// these will execute sequential 
NotSoHeavyTask1(); 
NotSoHeavyTask2(); 
NotSoHeavyTask3(); 

// loop through tasks to see if they are still active, and join them to main thread 
foreach (Thread T in Threadlist) 
    if (T.ThreadState == ThreadState.Running) 
    T.Join(); 

// finally this code will execute 
MoreTasksToDo();