Как я могу написать универсальный контейнерный класс, который реализует данный интерфейс в C #? - PullRequest
25 голосов
/ 11 мая 2009

Контекст: .NET 3.5, VS2008. Я не уверен насчет заголовка этого вопроса, поэтому не стесняйтесь комментировать и заголовок :-)

Вот сценарий: у меня есть несколько классов, скажем, Foo и Bar, все они реализуют следующий интерфейс:

public interface IStartable
{
    void Start();
    void Stop();
}

А теперь я хотел бы иметь контейнерный класс, который получает IEnumerable в качестве аргумента в своем конструкторе. Этот класс, в свою очередь, также должен реализовывать интерфейс IStartable:

public class StartableGroup : IStartable // this is the container class
{
    private readonly IEnumerable<IStartable> startables;

    public StartableGroup(IEnumerable<IStartable> startables)
    {
        this.startables = startables;
    }

    public void Start()
    {
        foreach (var startable in startables)
        {
            startable.Start();
        }
    }

    public void Stop()
    {
        foreach (var startable in startables)
        {
            startable.Stop();
        }
    }
}

Итак, мой вопрос: как я могу сделать это без написания кода вручную и без генерации кода? Другими словами, я хотел бы иметь что-то вроде следующего.

var arr = new IStartable[] { new Foo(), new Bar("wow") };
var mygroup = GroupGenerator<IStartable>.Create(arr);
mygroup.Start(); // --> calls Foo's Start and Bar's Start

Ограничения:

  • Нет генерации кода (то есть, нет реального текстового кода во время компиляции)
  • Интерфейс имеет только пустые методы, с аргументами или без них

Мотивация:

  • У меня довольно большое приложение с множеством плагинов различных интерфейсов. Написание вручную класса «контейнер группы» для каждого интерфейса «перегружает» проект классами
  • Написание кода вручную подвержено ошибкам
  • Любые добавления или обновления подписи интерфейса IStartable приведут к (ручному) изменению в классе «групповой контейнер»
  • Обучение

Я понимаю, что здесь нужно использовать рефлексию, но я бы предпочел использовать надежный фреймворк (например, DynamicProxy или RunSharp Касла), чтобы сделать для меня проводку. *

Есть мысли?

Ответы [ 7 ]

28 голосов
/ 11 мая 2009

Это не красиво, но, похоже, работает:

public static class GroupGenerator
{
    public static T Create<T>(IEnumerable<T> items) where T : class
    {
        return (T)Activator.CreateInstance(Cache<T>.Type, items);
    }
    private static class Cache<T> where T : class
    {
        internal static readonly Type Type;
        static Cache()
        {
            if (!typeof(T).IsInterface)
            {
                throw new InvalidOperationException(typeof(T).Name
                    + " is not an interface");
            }
            AssemblyName an = new AssemblyName("tmp_" + typeof(T).Name);
            var asm = AppDomain.CurrentDomain.DefineDynamicAssembly(
                an, AssemblyBuilderAccess.RunAndSave);
            string moduleName = Path.ChangeExtension(an.Name,"dll");
            var module = asm.DefineDynamicModule(moduleName, false);
            string ns = typeof(T).Namespace;
            if (!string.IsNullOrEmpty(ns)) ns += ".";
            var type = module.DefineType(ns + "grp_" + typeof(T).Name,
                TypeAttributes.Class | TypeAttributes.AnsiClass |
                TypeAttributes.Sealed | TypeAttributes.NotPublic);
            type.AddInterfaceImplementation(typeof(T));

            var fld = type.DefineField("items", typeof(IEnumerable<T>),
                FieldAttributes.Private);
            var ctor = type.DefineConstructor(MethodAttributes.Public,
                CallingConventions.HasThis, new Type[] { fld.FieldType });
            var il = ctor.GetILGenerator();
            // store the items
            il.Emit(OpCodes.Ldarg_0);
            il.Emit(OpCodes.Ldarg_1);
            il.Emit(OpCodes.Stfld, fld);
            il.Emit(OpCodes.Ret);

            foreach (var method in typeof(T).GetMethods())
            {
                var args = method.GetParameters();
                var methodImpl = type.DefineMethod(method.Name,
                    MethodAttributes.Private | MethodAttributes.Virtual,
                    method.ReturnType,
                    Array.ConvertAll(args, arg => arg.ParameterType));
                type.DefineMethodOverride(methodImpl, method);
                il = methodImpl.GetILGenerator();
                if (method.ReturnType != typeof(void))
                {
                    il.Emit(OpCodes.Ldstr,
                        "Methods with return values are not supported");
                    il.Emit(OpCodes.Newobj, typeof(NotSupportedException)
                        .GetConstructor(new Type[] {typeof(string)}));
                    il.Emit(OpCodes.Throw);
                    continue;
                }

                // get the iterator
                var iter = il.DeclareLocal(typeof(IEnumerator<T>));
                il.Emit(OpCodes.Ldarg_0);
                il.Emit(OpCodes.Ldfld, fld);
                il.EmitCall(OpCodes.Callvirt, typeof(IEnumerable<T>)
                    .GetMethod("GetEnumerator"), null);
                il.Emit(OpCodes.Stloc, iter);
                Label tryFinally = il.BeginExceptionBlock();

                // jump to "progress the iterator"
                Label loop = il.DefineLabel();
                il.Emit(OpCodes.Br_S, loop);

                // process each item (invoke the paired method)
                Label doItem = il.DefineLabel();
                il.MarkLabel(doItem);
                il.Emit(OpCodes.Ldloc, iter);
                il.EmitCall(OpCodes.Callvirt, typeof(IEnumerator<T>)
                    .GetProperty("Current").GetGetMethod(), null);
                for (int i = 0; i < args.Length; i++)
                { // load the arguments
                    switch (i)
                    {
                        case 0: il.Emit(OpCodes.Ldarg_1); break;
                        case 1: il.Emit(OpCodes.Ldarg_2); break;
                        case 2: il.Emit(OpCodes.Ldarg_3); break;
                        default:
                            il.Emit(i < 255 ? OpCodes.Ldarg_S
                                : OpCodes.Ldarg, i + 1);
                            break;
                    }
                }
                il.EmitCall(OpCodes.Callvirt, method, null);

                // progress the iterator
                il.MarkLabel(loop);
                il.Emit(OpCodes.Ldloc, iter);
                il.EmitCall(OpCodes.Callvirt, typeof(IEnumerator)
                    .GetMethod("MoveNext"), null);
                il.Emit(OpCodes.Brtrue_S, doItem);
                il.Emit(OpCodes.Leave_S, tryFinally);

                // dispose iterator
                il.BeginFinallyBlock();
                Label endFinally = il.DefineLabel();
                il.Emit(OpCodes.Ldloc, iter);
                il.Emit(OpCodes.Brfalse_S, endFinally);
                il.Emit(OpCodes.Ldloc, iter);
                il.EmitCall(OpCodes.Callvirt, typeof(IDisposable)
                    .GetMethod("Dispose"), null);
                il.MarkLabel(endFinally);
                il.EndExceptionBlock();
                il.Emit(OpCodes.Ret);
            }
            Cache<T>.Type = type.CreateType();
#if DEBUG       // for inspection purposes...
            asm.Save(moduleName);
#endif
        }
    }
}
4 голосов
/ 11 мая 2009

Это не такой чистый интерфейс, как решение на основе отражения, но очень простое и гибкое решение - создать метод ForAll, например:

static void ForAll<T>(this IEnumerable<T> items, Action<T> action)
{
    foreach (T item in items)
    {
        action(item);
    }
}

И можно назвать так:

arr.ForAll(x => x.Start());
2 голосов
/ 19 ноября 2009

Automapper является хорошим решением для этого. Он опирается на LinFu внизу для создания экземпляра, который реализует интерфейс, но он заботится о некоторой гидратации и смешивает под несколько плавным API. Автор LinFu утверждает, что на самом деле он намного легче и быстрее, чем Castle Proxy.

2 голосов
/ 11 мая 2009

Вы можете создать подкласс List<T> или какой-либо другой класс коллекции и использовать ограничение общего типа where, чтобы ограничить тип T только IStartable классами.

class StartableList<T> : List<T>, IStartable where T : IStartable
{
    public StartableList(IEnumerable<T> arr)
        : base(arr)
    {
    }

    public void Start()
    {
        foreach (IStartable s in this)
        {
            s.Start();
        }
    }

    public void Stop()
    {
        foreach (IStartable s in this)
        {
            s.Stop();
        }
    }
}

Вы также можете объявить класс следующим образом, если вы не хотите, чтобы он был универсальным классом, требующим параметр типа.

public class StartableList : List<IStartable>, IStartable
{ ... }

Ваш пример кода использования будет выглядеть примерно так:

var arr = new IStartable[] { new Foo(), new Bar("wow") };
var mygroup = new StartableList<IStartable>(arr);
mygroup.Start(); // --> calls Foo's Start and Bar's Start
0 голосов
/ 11 мая 2009

Если я правильно понимаю, вы запрашиваете реализацию "GroupGenerator".

Без какого-либо реального опыта работы с CastleProxy я бы порекомендовал использовать GetMethods (), чтобы получить начальные методы, перечисленные в интерфейсе, а затем создать новый тип на лету, используя Reflection.Emit с новыми методами, которые перечисляют объекты и вызовите каждый соответствующий метод. Производительность не должна быть слишком плохой.

0 голосов
/ 11 мая 2009

Вы можете использовать класс «Список» и их метод «ForEach».

var startables = new List<IStartable>( array_of_startables );
startables.ForEach( t => t.Start(); }
0 голосов
/ 11 мая 2009

Вы можете подождать C # 4.0 и использовать динамическое связывание.

Это отличная идея - мне приходилось реализовывать это для IDisposable несколько раз; когда я хочу избавиться от многих вещей. Однако следует помнить одну вещь: как будут обрабатываться ошибки. Если он войдет в систему и продолжит запускать другие и т. Д. Вам понадобятся некоторые опции, чтобы дать класс.

Я не знаком с DynamicProxy и как его можно использовать здесь.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...