Giao tiếp giữa các luồng. Làm thế nào để gửi một tín hiệu đến thread khác

Question

Trong ứng dụng của tôi, tôi có hai luồng

1. một "chủ đề chính", đó là bận rộn hầu hết thời gian
2. một "bổ sung chủ đề" mà gửi ra một số yêu cầu HTTP và sẽ chặn cho đến khi nhận được phản hồi.

Tuy nhiên, phản hồi HTTP chỉ có thể được xử lý bởi chuỗi chính, vì nó dựa trên bộ nhớ cục bộ và các chức năng không an toàn.

Tôi đang tìm cách cho biết chuỗi chính khi nhận được phản hồi HTTP và dữ liệu tương ứng. Các chủ đề chính nên bị gián đoạn bởi các chủ đề bổ sung và xử lý các phản ứng HTTP càng sớm càng tốt, và sau đó tiếp tục làm việc từ điểm mà nó bị gián đoạn trước đó.

• Một cách tôi có thể nghĩ về là thread thêm tạm ngưng các chủ đề chính sử dụng SuspendThread, bản TLS từ các chủ đề chính sử dụng một số lắp ráp nội tuyến, thực hiện các chức năng phản ứng xử lý bản thân và sơ yếu lý lịch các chủ đề chính sau .

• Một cách khác trong suy nghĩ của tôi là thiết lập điểm ngắt trên một địa chỉ cụ thể trong luồng chủ đề thứ hai, để luồng chính được thông báo khi con trỏ chỉ lệnh thứ hai bước vào điểm ngắt đó - và do đó - có đã nhận được phản hồi HTTP.

Tuy nhiên, cả hai phương pháp này dường như không độc đáo chút nào, chúng bị tổn thương ngay cả khi chỉ nghĩ về chúng và chúng trông không thực sự đáng tin cậy.

Tôi có thể sử dụng gì để làm gián đoạn chủ đề chính, nói rằng cần lịch sự và xử lý phản hồi HTTP trước khi thực hiện bất kỳ điều gì khác? Câu trả lời mà không phụ thuộc vào thư viện được đánh giá cao, nhưng tôi cũng sẽ mất một số phụ thuộc, nếu nó cung cấp một số giải pháp tốt đẹp.

Sau đây question (liên quan đến các giải pháp QueueUserAPC) đã được trả lời và giải thích rằng không có phương pháp an toàn để có một đẩy -behaviour trong trường hợp của tôi.

Answer 1

Đây có thể là một trong những thời điểm mà người ta tự làm việc theo ý tưởng rất cụ thể mà không xem xét lại bức tranh lớn hơn. Không có cơ chế số ít mà theo đó một luồng đơn lẻ có thể ngừng thực thi trong ngữ cảnh hiện tại của nó, hãy làm điều gì đó khác, và tiếp tục thực hiện tại đường chính xác mà từ đó nó đã phá vỡ. Nếu có thể, nó sẽ đánh bại mục đích có chủ đề ngay từ đầu. Như bạn đã đề cập, mà không lùi lại và xem xét lại kiến ​​trúc tổng thể, thanh lịch nhất của các tùy chọn của bạn dường như đang sử dụng một chuỗi khác để chờ phản hồi HTTP, có treo chuỗi chính ở vị trí an toàn, tự xử lý phản hồi , sau đó tiếp tục chuỗi chính. Trong trường hợp này, bạn có thể suy nghĩ lại liệu lưu trữ luồng-địa-đun vẫn có ý nghĩa hay nếu một thứ nào đó cao hơn trong phạm vi phù hợp hơn, vì bạn có thể lãng phí rất nhiều chu kỳ sao chép nó mỗi khi bạn ngắt chuỗi chính.

Answer 2

Có vẻ như câu trả lời có thể được khám phá từ Microsoft MSDN. Đặc biệt là từ phần này trên 'Synchronizing Execution of Multiple Threads'

Answer 3

Tôi có thể không hiểu câu hỏi, nhưng CreateSemaphore và WaitForSingleObject sẽ hoạt động. Nếu một chuỗi đang chờ semaphore, nó sẽ tiếp tục khi luồng khác báo hiệu nó.

Cập nhật dựa trên nhận xét: Chủ đề chính có thể gọi WaitForSingleObject với thời gian chờ là 0. Trong tình huống đó, nó sẽ tiếp tục ngay lập tức nếu semaphore không được báo hiệu. Các chủ đề chính sau đó có thể kiểm tra nó trên cơ sở định kỳ.

Answer 4

Nếu chủ đề chính của bạn là GUI thread tại sao không gửi tin nhắn Windows cho nó? Đó là tất cả những gì chúng ta làm để tương tác với win32 GUI từ các luồng công nhân.

Answer 5

Một cách để thực hiện việc này là xác định là định kỳ kiểm tra xem một phản hồi HTTP đã được nhận chưa.

Tốt hơn bạn nên nói những gì bạn đang cố gắng hoàn thành.

Answer 6

Điều bạn mô tả là những gì QueueUserAPC thực hiện. Nhưng khái niệm sử dụng nó cho loại đồng bộ hóa này làm tôi hơi khó chịu. Nếu bạn không biết rằng chuỗi chính nằm trong một địa chỉ an toàn an toàn để làm gián đoạn, thì có thể bạn không nên làm gián đoạn nó.

Tôi nghi ngờ bạn nên tắt công việc của luồng chính cho một chuỗi khác để có thể ngồi và chờ bạn gửi thông báo để xử lý công việc mà chỉ có thể xử lý.

PostMessage hoặc PostThreadMessage thường hoạt động thực sự tốt để phân phát bit công việc cho chuỗi chính của bạn. Các tin nhắn đã đăng được xử lý trước các thông báo nhập của người dùng, nhưng không phải cho đến khi chuỗi đã sẵn sàng cho chúng.

Answer 7

Trong trường hợp này, tôi sẽ làm một vài việc. Đầu tiên và trước hết tôi sẽ tái cấu trúc công việc mà sợi chính đang làm để được chia nhỏ thành từng mảnh càng tốt. Điều đó mang lại cho bạn một loạt các địa điểm an toàn để thực hiện tại. Sau đó, bạn muốn tạo một hàng đợi công việc, có thể bằng cách sử dụng thanh trượt microsoft. Các slist sẽ cung cấp cho bạn khả năng để có thêm một thread trong khi người khác đọc mà không cần phải khóa.

Một khi bạn đã có tại chỗ bạn về cơ bản có thể làm cho chủ đề chính của bạn chạy trong một vòng lặp trên mỗi phần công việc, kiểm tra định kỳ để xem có yêu cầu xử lý trong hàng đợi hay không. Về lâu dài, điều tốt đẹp về kiến ​​trúc như vậy là bạn có thể dễ dàng loại bỏ lưu trữ cục bộ luồng và song song luồng chính bằng cách chuyển đổi dấu gạch chéo thành hàng đợi công việc (có thể vẫn đang sử dụng dấu gạch ngang) và tạo các phần công việc nhỏ và các phản hồi vào các đối tượng công việc có thể được phân phối động trên tất cả các chuỗi có sẵn.