Trình mở rộng phản ứng (RX) Bộ lập lịch tùy chỉnh C#

Question

Có thể xây dựng một bộ lập lịch tùy chỉnh có thể kiểm tra giá trị của mọi phần tử đi qua IObservable hay không, để quyết định chuỗi nào sẽ xử lý mục đó?

Tôi có yêu cầu xử lý các mục có cùng khóa liên tiếp nhưng các khóa khác nhau song song. Nó sẽ làm cho tinh thần để có RX làm việc lập kế hoạch hơn là phải rời khỏi quan sát sớm hơn tôi muốn để phân bổ mỗi giá trị cho một sợi.

Answer 1

Bạn đã thử GroupBy theo sau là ObserveOn?

Cái gì như:

source 
    .GroupBy(item => item.Key) 
    .SelectMany(group => group 
     .ObserveOn(Scheduler.NewThread) 
     .Select(item => process(item)) 
    ) 
    .Subscribe(processResult => ...); 

này sẽ phân vùng suối theo mã, bắt đầu một chủ đề mới cho mỗi phím, và chạy process() cho mỗi mục trong khóa đó.