neuecc

//<Project Sdk="Microsoft.NET.Sdk">
//	<PropertyGroup>
//		<OutputType>Exe</OutputType>
//		<TargetFramework>net6.0</TargetFramework>
//		<ImplicitUsings>enable</ImplicitUsings>
//		<Nullable>enable</Nullable>
//	</PropertyGroup>
//	<ItemGroup>
//		<PackageReference Include="BenchmarkDotNet" Version="0.13.2" />
//      <PackageReference Include="MessagePack" Version="2.4.35" />

neuecc

public async Task SendAsync(CancellationToken cancellationToken = default)
{
    var timeoutTokenSource = timeoutTokenSourcePool.Get();

    CancellationTokenRegistration externalCancellation = default;
    if (cancellationToken.CanBeCanceled)
    {
        externalCancellation = cancellationToken.UnsafeRegister(static state =>
        {
            ((CancellationTokenSource)state!).Cancel();

neuecc

class Client : IDisposable
{
    readonly TimeSpan timeout;
    readonly ObjectPool<CancellationTokenSource> timeoutTokenSourcePool;
    readonly CancellationTokenSource clientLifetimeTokenSource;

    public TimeSpan Timeout { get; }

    public Client(TimeSpan timeout)
    {

neuecc

public async Task SendAsync(CancellationToken cancellationToken = default)
{
    var timeoutTokenSource = timeoutTokenSourcePool.Get();

    CancellationTokenRegistration externalCancellation = default;
    if (cancellationToken.CanBeCanceled)
    {
        // When raised argument CancellationToken, raise Timeout's CancellationToken
        externalCancellation = cancellationToken.UnsafeRegister(static state =>
        {

neuecc

class Client
{
    // For classes that prohibit multiple calls to methods such as SqlConnection, add a single CancellationTokenSource to the field
    // Things like HttpClient, which may be called multiple times, are held in ObjectPool.
    
    readonly ObjectPool<CancellationTokenSource> timeoutTokenSourcePool;

    public TimeSpan Timeout { get; }

    public Client(TimeSpan timeout)

neuecc

public async Task SendAsync(CancellationToken cancellationToken = default)
{
    using var cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
    cts.CancelAfter(Timeout);

    try
    {
        await SendCoreAsync(cts.Token);
    }
    catch (OperationCanceledException ex) when (ex.CancellationToken == cts.Token)

neuecc

class Client : IDisposable
{
    // called from IDisposable.Dispose
    readonly CancellationTokenSource clientLifetimeTokenSource;

    public TimeSpan Timeout { get; }

    public Client(TimeSpan timeout)
    {
        this.Timeout = timeout;

neuecc

try
{
    await client.SendAsync(token);
}
catch (OperationCanceledException ex) when (ex.CancellationToken == token)
{
    // detect reason of Cancel by Token
}

neuecc

class Client
{
    public TimeSpan Timeout { get; }

    public Client(TimeSpan timeout)
    {
        this.Timeout = timeout;
    }

    public async Task SendAsync(CancellationToken cancellationToken = default)

neuecc

// Dispose will stop internal timer to prevent timer leak
using var cts = new CancellationTokenSource();
cts.CancelAfter(TimeSpan.FromMinutes(1));

await client.SendAsync(cts.Token);