How to use TaskServices class of Microsoft.Coyote.Runtime package

Best Coyote code snippet using Microsoft.Coyote.Runtime.TaskServices

ConfiguredValueTaskAwaitable.cs

Source:ConfiguredValueTaskAwaitable.cs

...76            /// Ends asynchronously waiting for the completion of the awaiter.77            /// </summary>78            public void GetResult()79            {80                TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);81                this.Awaiter.GetResult();82            }83            /// <summary>84            /// Schedules the continuation action for the value task associated with this awaiter.85            /// </summary>86            /// <param name="continuation">The action to invoke when the await operation completes.</param>87            public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);88            /// <summary>89            /// Schedules the continuation action for the value task associated with this awaiter.90            /// </summary>91            /// <param name="continuation">The action to invoke when the await operation completes.</param>92            public void UnsafeOnCompleted(Action continuation) => this.Awaiter.UnsafeOnCompleted(continuation);93        }94    }95    /// <summary>96    /// Provides an awaitable object that enables configured awaits on a <see cref="SystemTasks.ValueTask{TResult}"/>.97    /// </summary>98    /// <remarks>This type is intended for compiler use only.</remarks>99    [System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]100    public struct ConfiguredValueTaskAwaitable<TResult>101    {102        /// <summary>103        /// The value task awaiter.104        /// </summary>105        private readonly ConfiguredValueTaskAwaiter Awaiter;106        /// <summary>107        /// Initializes a new instance of the <see cref="ConfiguredValueTaskAwaitable{TResult}"/> struct.108        /// </summary>109        internal ConfiguredValueTaskAwaitable(ref SystemTasks.ValueTask<TResult> awaitedTask, bool continueOnCapturedContext)110        {111            this.Awaiter = new ConfiguredValueTaskAwaiter(ref awaitedTask, continueOnCapturedContext);112        }113        /// <summary>114        /// Returns an awaiter for this awaitable object.115        /// </summary>116        /// <returns>The awaiter.</returns>117        public ConfiguredValueTaskAwaiter GetAwaiter() => this.Awaiter;118        /// <summary>119        /// Provides an awaiter for an awaitable object.120        /// </summary>121        /// <remarks>This type is intended for compiler use only.</remarks>122        public struct ConfiguredValueTaskAwaiter : IControllableAwaiter, SystemCompiler.ICriticalNotifyCompletion, SystemCompiler.INotifyCompletion123        {124            /// <summary>125            /// The inner task being awaited.126            /// </summary>127            private readonly SystemTasks.Task<TResult> AwaitedTask;128            /// <summary>129            /// The value task awaiter.130            /// </summary>131            private readonly SystemCompiler.ConfiguredValueTaskAwaitable<TResult>.ConfiguredValueTaskAwaiter Awaiter;132            /// <summary>133            /// The runtime controlling this awaiter.134            /// </summary>135            private readonly CoyoteRuntime Runtime;136            /// <summary>137            /// True if the awaiter has completed, else false.138            /// </summary>139            public bool IsCompleted => this.AwaitedTask?.IsCompleted ?? this.Awaiter.IsCompleted;140            /// <inheritdoc/>141            bool IControllableAwaiter.IsControlled =>142                !this.Runtime?.IsTaskUncontrolled(this.AwaitedTask) ?? false;143            /// <summary>144            /// Initializes a new instance of the <see cref="ConfiguredValueTaskAwaiter"/> struct.145            /// </summary>146            internal ConfiguredValueTaskAwaiter(ref SystemTasks.ValueTask<TResult> awaitedTask, bool continueOnCapturedContext)147            {148                if (RuntimeProvider.TryGetFromSynchronizationContext(out CoyoteRuntime runtime))149                {150                    // Force the continuation to run on the current context so that it can be controlled.151                    continueOnCapturedContext = true;152                }153                this.AwaitedTask = ValueTaskAwaiter.TryGetTask<TResult>(ref awaitedTask, out SystemTasks.Task<TResult> innerTask) ?154                    innerTask : null;155                this.Awaiter = awaitedTask.ConfigureAwait(continueOnCapturedContext).GetAwaiter();156                this.Runtime = runtime;157            }158            /// <summary>159            /// Ends asynchronously waiting for the completion of the awaiter.160            /// </summary>161            public TResult GetResult()162            {163                TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);164                return this.Awaiter.GetResult();165            }166            /// <summary>167            /// Schedules the continuation action for the value task associated with this awaiter.168            /// </summary>169            /// <param name="continuation">The action to invoke when the await operation completes.</param>170            public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);171            /// <summary>172            /// Schedules the continuation action for the value task associated with this awaiter.173            /// </summary>174            /// <param name="continuation">The action to invoke when the await operation completes.</param>175            public void UnsafeOnCompleted(Action continuation) => this.Awaiter.UnsafeOnCompleted(continuation);176        }177    }...

ConfiguredTaskAwaitable.cs

Source:ConfiguredTaskAwaitable.cs

...74            /// Ends asynchronously waiting for the completion of the awaiter.75            /// </summary>76            public void GetResult()77            {78                TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);79                this.Awaiter.GetResult();80            }81            /// <summary>82            /// Schedules the continuation action for the task associated with this awaiter.83            /// </summary>84            /// <param name="continuation">The action to invoke when the await operation completes.</param>85            public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);86            /// <summary>87            /// Schedules the continuation action for the task associated with this awaiter.88            /// </summary>89            /// <param name="continuation">The action to invoke when the await operation completes.</param>90            public void UnsafeOnCompleted(Action continuation) => this.Awaiter.UnsafeOnCompleted(continuation);91        }92    }93    /// <summary>94    /// Provides an awaitable object that enables configured awaits on a <see cref="SystemTasks.Task{TResult}"/>.95    /// </summary>96    /// <remarks>This type is intended for compiler use only.</remarks>97    [System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]98    public struct ConfiguredTaskAwaitable<TResult>99    {100        /// <summary>101        /// The task awaiter.102        /// </summary>103        private readonly ConfiguredTaskAwaiter Awaiter;104        /// <summary>105        /// Initializes a new instance of the <see cref="ConfiguredTaskAwaitable{TResult}"/> struct.106        /// </summary>107        internal ConfiguredTaskAwaitable(SystemTasks.Task<TResult> awaitedTask, bool continueOnCapturedContext)108        {109            this.Awaiter = new ConfiguredTaskAwaiter(awaitedTask, continueOnCapturedContext);110        }111        /// <summary>112        /// Returns an awaiter for this awaitable object.113        /// </summary>114        /// <returns>The awaiter.</returns>115        public ConfiguredTaskAwaiter GetAwaiter() => this.Awaiter;116        /// <summary>117        /// Provides an awaiter for an awaitable object.118        /// </summary>119        /// <remarks>This type is intended for compiler use only.</remarks>120        public struct ConfiguredTaskAwaiter : IControllableAwaiter, SystemCompiler.ICriticalNotifyCompletion, SystemCompiler.INotifyCompletion121        {122            /// <summary>123            /// The task being awaited.124            /// </summary>125            private readonly SystemTasks.Task<TResult> AwaitedTask;126            /// <summary>127            /// The task awaiter.128            /// </summary>129            private readonly SystemCompiler.ConfiguredTaskAwaitable<TResult>.ConfiguredTaskAwaiter Awaiter;130            /// <summary>131            /// The runtime controlling this awaiter.132            /// </summary>133            private readonly CoyoteRuntime Runtime;134            /// <summary>135            /// True if the awaiter has completed, else false.136            /// </summary>137            public bool IsCompleted => this.AwaitedTask?.IsCompleted ?? this.Awaiter.IsCompleted;138            /// <inheritdoc/>139            bool IControllableAwaiter.IsControlled =>140                !this.Runtime?.IsTaskUncontrolled(this.AwaitedTask) ?? false;141            /// <summary>142            /// Initializes a new instance of the <see cref="ConfiguredTaskAwaiter"/> struct.143            /// </summary>144            internal ConfiguredTaskAwaiter(SystemTasks.Task<TResult> awaitedTask, bool continueOnCapturedContext)145            {146                if (RuntimeProvider.TryGetFromSynchronizationContext(out CoyoteRuntime runtime))147                {148                    // Force the continuation to run on the current context so that it can be controlled.149                    continueOnCapturedContext = true;150                }151                this.AwaitedTask = awaitedTask;152                this.Awaiter = awaitedTask.ConfigureAwait(continueOnCapturedContext).GetAwaiter();153                this.Runtime = runtime;154            }155            /// <summary>156            /// Ends asynchronously waiting for the completion of the awaiter.157            /// </summary>158            public TResult GetResult()159            {160                TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);161                return this.Awaiter.GetResult();162            }163            /// <summary>164            /// Schedules the continuation action for the task associated with this awaiter.165            /// </summary>166            /// <param name="continuation">The action to invoke when the await operation completes.</param>167            public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);168            /// <summary>169            /// Schedules the continuation action for the task associated with this awaiter.170            /// </summary>171            /// <param name="continuation">The action to invoke when the await operation completes.</param>172            public void UnsafeOnCompleted(Action continuation) => this.Awaiter.UnsafeOnCompleted(continuation);173        }174    }...

TaskAwaiter.cs

Source:TaskAwaiter.cs

...60        /// Ends asynchronously waiting for the completion of the awaiter.61        /// </summary>62        public void GetResult()63        {64            TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);65            this.Awaiter.GetResult();66        }67        /// <summary>68        /// Sets the action to perform when the controlled task completes.69        /// </summary>70        [MethodImpl(MethodImplOptions.AggressiveInlining)]71        public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);72        /// <summary>73        /// Schedules the continuation action that is invoked when the controlled task completes.74        /// </summary>75        [MethodImpl(MethodImplOptions.AggressiveInlining)]76        public void UnsafeOnCompleted(Action continuation)77        {78            this.Awaiter.UnsafeOnCompleted(continuation);79        }80        /// <summary>81        /// Wraps the specified task awaiter.82        /// </summary>83        public static TaskAwaiter Wrap(SystemCompiler.TaskAwaiter awaiter)84        {85            // Access the task being awaited through reflection.86            var field = awaiter.GetType().GetField("m_task", BindingFlags.NonPublic | BindingFlags.Instance);87            var awaitedTask = (SystemTask)field?.GetValue(awaiter);88            return new TaskAwaiter(awaitedTask, ref awaiter);89        }90        /// <summary>91        /// Wraps the specified generic task awaiter.92        /// </summary>93        public static TaskAwaiter<TResult> Wrap<TResult>(SystemCompiler.TaskAwaiter<TResult> awaiter)94        {95            // Access the generic task being awaited through reflection.96            var field = awaiter.GetType().GetField("m_task", BindingFlags.NonPublic | BindingFlags.Instance);97            var awaitedTask = (SystemTasks.Task<TResult>)field?.GetValue(awaiter);98            return new TaskAwaiter<TResult>(awaitedTask, ref awaiter);99        }100    }101    /// <summary>102    /// Implements a generic task awaiter.103    /// </summary>104    /// <typeparam name="TResult">The type of the produced result.</typeparam>105    /// <remarks>This type is intended for compiler use only.</remarks>106    [System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]107    public readonly struct TaskAwaiter<TResult> : IControllableAwaiter, ICriticalNotifyCompletion, INotifyCompletion108    {109        // WARNING: The layout must remain the same, as the struct is used to access110        // the generic TaskAwaiter<> as TaskAwaiter.111        /// <summary>112        /// The task being awaited.113        /// </summary>114        private readonly SystemTasks.Task<TResult> AwaitedTask;115        /// <summary>116        /// The task awaiter.117        /// </summary>118        private readonly SystemCompiler.TaskAwaiter<TResult> Awaiter;119        /// <summary>120        /// The runtime controlling this awaiter.121        /// </summary>122        private readonly CoyoteRuntime Runtime;123        /// <summary>124        /// True if the awaiter has completed, else false.125        /// </summary>126        public bool IsCompleted => this.AwaitedTask?.IsCompleted ?? this.Awaiter.IsCompleted;127        /// <inheritdoc/>128        bool IControllableAwaiter.IsControlled =>129            !this.Runtime?.IsTaskUncontrolled(this.AwaitedTask) ?? false;130        /// <summary>131        /// Initializes a new instance of the <see cref="TaskAwaiter{TResult}"/> struct.132        /// </summary>133        internal TaskAwaiter(SystemTasks.Task<TResult> awaitedTask)134        {135            this.AwaitedTask = awaitedTask;136            this.Awaiter = awaitedTask.GetAwaiter();137            RuntimeProvider.TryGetFromSynchronizationContext(out CoyoteRuntime runtime);138            this.Runtime = runtime;139        }140        /// <summary>141        /// Initializes a new instance of the <see cref="TaskAwaiter{TResult}"/> struct.142        /// </summary>143        internal TaskAwaiter(SystemTasks.Task<TResult> awaitedTask, ref SystemCompiler.TaskAwaiter<TResult> awaiter)144        {145            this.AwaitedTask = awaitedTask;146            this.Awaiter = awaiter;147            RuntimeProvider.TryGetFromSynchronizationContext(out CoyoteRuntime runtime);148            this.Runtime = runtime;149        }150        /// <summary>151        /// Ends asynchronously waiting for the completion of the awaiter.152        /// </summary>153        public TResult GetResult()154        {155            TaskServices.WaitUntilTaskCompletes(this.Runtime, this.AwaitedTask);156            return this.Awaiter.GetResult();157        }158        /// <summary>159        /// Sets the action to perform when the controlled task completes.160        /// </summary>161        [MethodImpl(MethodImplOptions.AggressiveInlining)]162        public void OnCompleted(Action continuation) => this.Awaiter.OnCompleted(continuation);163        /// <summary>164        /// Schedules the continuation action that is invoked when the controlled task completes.165        /// </summary>166        [MethodImpl(MethodImplOptions.AggressiveInlining)]167        public void UnsafeOnCompleted(Action continuation) => this.Awaiter.UnsafeOnCompleted(continuation);168    }169}...

TaskServices

Using AI Code Generation

1using Microsoft.Coyote.Runtime;2{3    {4        static void Main(string[] args)5        {6            TaskServices.StartTask(MainTask);7        }8        static async Task MainTask()9        {10            Console.WriteLine("Hello World!");11            await Task.Delay(1000);12        }13    }14}15using Microsoft.Coyote.Runtime;16{17    {18        static void Main(string[] args)19        {20            TaskServices.StartTask(MainTask);21        }22        static async Task MainTask()23        {24            Console.WriteLine("Hello World!");25            await Task.Delay(1000);26        }27    }28}29I tried to add the Microsoft.Coyote.Runtime package to the project, but I get the following error: "Package 'Microsoft.Coyote.Runtime 1.0.0' is not compatible with 'netcoreapp3.1' (.NETCoreApp,Version=v3.1). Package 'Microsoft.Coyote.Runtime 1.0.0' supports: netstandard2.0 (.NETStandard,Version=v2.0)"30I tried to add the Microsoft.Coyote.Runtime package to the project using the following command: "dotnet add package Microsoft.Coyote.Runtime --version 1.0.0", but I get the following error: "error NU1202: Package Microsoft.Coyote.Runtime 1.0.0 is not compatible with netcoreapp3.1 (.NETCoreApp,Version=v3.1). Package Microsoft.Coyote.Runtime 1.0.0 supports: netstandard2.0 (.NETStandard,Version=v2.0)"

TaskServices

Using AI Code Generation

1using Microsoft.Coyote;2using Microsoft.Coyote.Actors;3using Microsoft.Coyote.Tasks;4using System;5{6    {7        static void Main(string[] args)8        {9            TaskServices.RunMainAsync(MainAsync()).Wait();10        }11        static async Task MainAsync()12        {13            await TaskServices.CreateActorAsync(typeof(HelloActor), null);14        }15    }16    {17        protected override async Task OnInitializeAsync(Event initialEvent)18        {19            await this.SendEventAsync(this.Id, new HelloEvent());20        }21        protected override Task OnEventAsync(Event e)22        {23            switch (e)24            {25                    Console.WriteLine("Hello from actor!");26                    break;27            }28            return Task.CompletedTask;29        }30    }31    {32    }33}

TaskServices

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using Microsoft.Coyote;4using Microsoft.Coyote.Actors;5using Microsoft.Coyote.Tasks;6using System.Collections.Generic;7using System.Threading;8using System.Linq;9{10    {11        static void Main(string[] args)12        {13            TaskServices.Run(async () =>14            {15                var t = TaskServices.CreateTask(() => Console.WriteLine("Hello World!"));16                await t;17            });18        }19    }20}21using System;22using System.Threading.Tasks;23using Microsoft.Coyote;24using Microsoft.Coyote.Actors;25using Microsoft.Coyote.Tasks;26using System.Collections.Generic;27using System.Threading;28using System.Linq;29{30    {31        static void Main(string[] args)32        {33            TaskServices.Run(async () =>34            {35                var t = TaskServices.CreateTask(() => Console.WriteLine("Hello World!"));36                await t;37            });38        }39    }40}

TaskServices

Using AI Code Generation

1using System;2using Microsoft.Coyote.Runtime;3using System.Threading.Tasks;4{5    {6        static void Main(string[] args)7        {8            var runtime = TaskServices.CreateRuntime();9            runtime.CreateActor(typeof(HelloWorldActor));10            runtime.Run();11        }12    }13}14using System;15using Microsoft.Coyote;16using Microsoft.Coyote.Actors;17{18    {19        protected override Task OnInitializeAsync(Event initialEvent)20        {21            Console.WriteLine("Hello World!");22            this.SendEvent(this.Id, HaltEvent.Instance);23            return Task.CompletedTask;24        }25    }26}

TaskServices

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using Microsoft.Coyote.Runtime;4{5    {6        static void Main(string[] args)7        {8            Console.WriteLine("Hello World!");9        }10    }11}

TaskServices

Using AI Code Generation

1{2    {3        public void DoWork()4        {5            Console.WriteLine("Worker.DoWork() started");6            Thread.Sleep(1000);7            Console.WriteLine("Worker.DoWork() finished");8        }9    }10    {11        static void Main(string[] args)12        {13            Console.WriteLine("Program.Main() started");14            var runtime = TaskServices.CreateTaskRuntime();15            var worker = new Worker();16            var task = runtime.CreateTask(() => worker.DoWork());17            task.Start();18            task.Wait();19            runtime.Dispose();20            Console.WriteLine("Program.Main() finished");21        }22    }23}24Program.Main() started25Worker.DoWork() started26Worker.DoWork() finished27Program.Main() finished

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.