AgentPoolManager.Core
1.0.0
dotnet add package AgentPoolManager.Core --version 1.0.0
NuGet\Install-Package AgentPoolManager.Core -Version 1.0.0
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="AgentPoolManager.Core" Version="1.0.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add AgentPoolManager.Core --version 1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: AgentPoolManager.Core, 1.0.0"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install AgentPoolManager.Core as a Cake Addin #addin nuget:?package=AgentPoolManager.Core&version=1.0.0 // Install AgentPoolManager.Core as a Cake Tool #tool nuget:?package=AgentPoolManager.Core&version=1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
Agent Pool Manager Core
Manages a pool of asynchronous methods (agents) that keep repeating at a given interval until they are requested to stop. This lets your IIS Web applicaiton runs a pool of tasks in the background.
Interfaces
This nuGet has only one public class implementing the following interface
IAgentPoolManager
using System;
using System.Collections.Generic;
using System.Threading;
namespace pvWay.AgentPoolManager.Core
{
public interface IAgentPoolManager
{
IEnumerable<IAgent> Agents { get; }
IAgent GetAgent(Guid id);
IAgent StartAgent<T>(
string title,
Action<T> repeat,
T workerParam,
TimeSpan sleepSpan,
ThreadPriority priority = ThreadPriority.Normal,
Action<IAgent> stopCallback = null);
IAgent StartAgent(
string title,
Action repeat,
TimeSpan sleepSpan,
ThreadPriority priority = ThreadPriority.Normal,
Action<IAgent> stopCallback = null);
}
}
IAgent
using System;
namespace pvWay.AgentPoolManager.Core
{
public interface IAgent
{
Guid Id { get; }
DateTime StartTimeUtc { get; }
string Title { get; }
void RequestToStop();
}
}
Usage
See here after a short Console that use the pool
Principe
- Create a method (with or without parameter) that you want to repeatedly invoke in background
- Determine the interval of time between two invocations of your method
- Instantiate the PoolManager (you can wrap/inject this class into/as a Singleton)
- Add your method into the Agent Pool and in return get a IAgent reference
- Stop the method at any time by calling the IAgent RequestToStop method
The following example shows the code for a simple clock pulsar that write the time in the console every 5 seconds.
The code
using System;
using System.Threading;
using pvWay.AgentPoolManager.Core;
namespace AgentPoolManagerLab.Core
{
internal static class Program
{
private static void Main(/*string[] args*/)
{
var apm = new PoolManager();
var pulsar = apm.StartAgent(
// the name of the asynchronous agent
"pulsar",
// the method to repeat asynchronously
Pulsar,
// the string param passed to the Pulsar method
"clock",
// time between each invocation
TimeSpan.FromSeconds(5),
// the priority
ThreadPriority.Normal,
// the lambda that is called when the pulsar is stopped
agent => Console.WriteLine($"{agent.Title} is stopped"));
Console.WriteLine("hit a key to stop");
Console.ReadKey();
pulsar.RequestToStop();
Console.WriteLine("hit a key to quit");
Console.ReadKey();
}
private static void Pulsar(string prefix)
{
Console.WriteLine($"{prefix}-{DateTime.Now:HH:mm:ss}");
}
}
}
Happy coding
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp3.1 is compatible. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
.NETCoreApp 3.1
- No dependencies.
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
1.0.0 | 492 | 8/25/2020 |
Initial