Здравствуйте, ребята, я пытаюсь создать свои Task -подобные типы, используя AsyncMethodBuilderAttribute для .NetCore framework.
Пока что. Net Core мой пользовательский Type работает, и он может быть awaited, и я могу вернуть его как async [MyTypeName]<T> MyMethod() вместо Task.
Однако в .NetStandard 2.0 атрибута нет, и я попытался его реализовать:
Я украсил свой ожидаемый тип атрибутом, но он все еще не позволяет мне его использовать: "The return type of an async method must be void,Task,Task<T>"
Пока что я могу использовать что-то вроде этого в. Net Core и это работает !!
public async Task WrapperMethod(){
int result=await GetIntAsync();
}
public async Errand<int> GetIntAsync()
{
await Task.Delay(1000);
return 3;
}
Атрибут
[AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Enum | AttributeTargets.Interface | AttributeTargets.Delegate, Inherited = false, AllowMultiple = false)]
public sealed class AsyncMethodBuilderAttribute : Attribute {
//
// Parameters:
// builderType:
public AsyncMethodBuilderAttribute(Type builderType) {
this.BuilderType = builderType;
}
//
public Type BuilderType { get; }
}
Ниже приведена реализация пользовательского типа, и async method builder. awaiter в данном случае не важен, но я могу предоставить источник при необходимости.
Мой Task -Как тип
[AsyncMethodBuilder(typeof(Builder))]
public partial class Errand {
private readonly Builder mbuilder;
public Errand() {
}
internal Errand(Builder methodBuilder) => this.mbuilder = methodBuilder;
private readonly HashSet<Awaiter> awaiters = new HashSet<Awaiter>();
protected bool isCompleted = false;
public Awaiter GetAwaiter() {
Awaiter result = new Awaiter(this);
this.awaiters.Add(result);
return result;
}
}
Пользовательская AsyncMethodBuilder реализация:
public partial class Builder {
#region " Compiler integration "
public static Builder Create() {
return new Builder();
}
protected IAsyncStateMachine myStateMachine;
public void Start<TStateMachine>(ref TStateMachine stateMachine) where TStateMachine : IAsyncStateMachine {
this.myStateMachine = stateMachine;
this.errand = new Errand(this);
stateMachine.MoveNext();
}
public void SetException(Exception ex) {
}
public void AwaitOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine machine) where TAwaiter : INotifyCompletion where TStateMachine : IAsyncStateMachine {
var foo = machine as IAsyncStateMachine;
awaiter.OnCompleted(() => { foo.MoveNext(); });
}
public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine machine)where TAwaiter : INotifyCompletion where TStateMachine : IAsyncStateMachine {
IAsyncStateMachine asyncMachine = machine as IAsyncStateMachine;
awaiter.OnCompleted(() => asyncMachine.MoveNext());
}
private Errand errand;
public Errand Task { get { return this.errand; } }
public void SetStateMachine(IAsyncStateMachine stateMachine) {
}
public void SetResult() {
}
#endregion
// internal void AddAwaiter(Awaiter awaiter) => this.awaiters.Add(awaiter);
}
Что еще я должен добавить для работы в .Net Standard?