0

単純なインターフェイスのセットと、アイテムの追加と削除を汎用ディクショナリに公開できるクラスを作成しました。サブスクライバーは、サブスクライブ時にリスト全体を受け取り、その後は変更のみを受け取ります。

私のソリューションは機能しますが、もう少し標準的なもの、もう少し自家製のものを探しています。何か提案はありますか？

私がこれまでに見つけたものに関するメモ：

私はMicrosoftのReactiveExtensions（Rx）を見てきました。JonSkeetの記事「LINQtoRx：secondimpressions」[1]によると、「オブザーバブルがサブスクライブするとすぐに、オブザーバブルはシーケンス内のすべてを（デフォルトでは別のスレッドで）公開します。サブスクライブへの個別の呼び出しオブザーバブルをシーケンス全体で複数回繰り返すようにします。」これは基本的な考え方のように聞こえますが、具体的な例が見つからず、「Subject」または「AsyncSubject」のスレッドセーフについてはまだよくわかりません。

私の自家製ソリューションに関するメモ：

サブスクライバーに配信される構造は次のようになります。

/// <summary>
/// Interface for a set of changes that are being published.
/// </summary>
/// <typeparam name="TKey"></typeparam>
/// <typeparam name="TItem"></typeparam>
public interface IPublication<TKey, TItem>
{
    /// <summary>
    /// Version of the list.
    /// </summary>
    long Version { get; }
    /// <summary>
    /// Items that were added or updated.
    /// </summary>
    IEnumerable<TItem> ChangedItems { get; }
    /// <summary>
    /// Keys to items that were removed.
    /// </summary>
    IEnumerable<TKey> RemovedKeys { get; }
}

サブスクライバー自身がこのインターフェースを実装する必要があります。

/// <summary>
/// Interface for a subscriber that will receive IPublication{TKey, TItem} deliveries from a publisher.
/// </summary>
/// <typeparam name="TKey"></typeparam>
/// <typeparam name="TItem"></typeparam>
public interface ISubscribe<TKey, TItem>
{
    void Deliver(IPublication<TKey, TItem> pub);
}

そしてもちろん、私の汎用辞書パブリッシャークラスには次のメソッドがあります。

/// <summary>
/// Adds the give subscriber to the list of subscribers and immediately publishes the
/// dictionary contents to the new subscriber. The return value may be disposed when
/// the subscriber wishes to terminate it's subscription.
/// </summary>
/// <param name="subscriber"></param>
/// <returns></returns>
public IDisposable Subscribe(ISubscribe<TKey, TItem> subscriber);

[1] https://codeblog.jonskeet.uk/2010/01/19/linq-to-rx-second-impressions/

4

1 に答える 1

1

これは実際には答えではありませんが、コメントに入れるのは面倒なので、ここに入れてください...カスタムソリューションの構築が簡単で機能するのに、なぜ標準のすぐに使えるソリューションを検討しているのかわかりません。イベントは、パブリッシャー-サブスクライバーモデルを実現するための最も単純な（そして標準的な）方法ですが、スレッドセーフではなく、サブスクライバーとパブリッシャーの間の緊密な結合にも悩まされています。MSパターン＆プラクティスグループはWCFベースのパターンを公開していましたが、高速なインプロセスの種類のコードを探していると思います。同様に、他の多くの標準のパブリッシュ/サブスクライブソリューションは、アプリケーション統合（ESB）を対象としています。代替案が見つからず、カスタムソリューションを使用することにした場合は、このアーティクルを参照してください。これは、このデザインパターンを実装する際の問題を説明しています。

于 2010-08-17T05:47:26.083 に答える