Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests 클래스 참조

더 자세히 ...

클래스
class	CpuUsageProvider

Public 멤버 함수
void	ThreadOptions_NormalizeRepairsInvalidValues ()
void	ThreadJobOptions_NormalizeRepairsInvalidValues ()
void	FixedAndOverflowPolicies_ReturnExpectedDelays ()
void	AdaptiveCpuPolicy_ReturnsDelayByCpuUsage (double cpuUsage, int expectedDelay)
void	CoreAssignmentFactories_ExposeExpectedFlags ()
void	ThreadingRegistration_UsesFixedPolicyWhenCpuUsageProviderIsMissing ()
void	ThreadOptions_NormalizeRepairsInvalidStopTimeout ()

상세한 설명

Threading Policy Tests 기능과 관련 상태를 캡슐화합니다.

ThreadingPolicyTests.cs 파일의 20 번째 라인에서 정의되었습니다.

멤버 함수 문서화

AdaptiveCpuPolicy_ReturnsDelayByCpuUsage()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.AdaptiveCpuPolicy_ReturnsDelayByCpuUsage ( double cpuUsage, int expectedDelay )

inline

Adaptive Cpu Policy Returns Delay By Cpu Usage 작업을 수행합니다.

매개변수

cpuUsage	cpu Usage에 사용할 double 값입니다.
expectedDelay	expected Delay에 사용할 int 값입니다.

ThreadingPolicyTests.cs 파일의 116 번째 라인에서 정의되었습니다.

    {
        var policy = new AdaptiveCpuCyclePolicy(new CpuUsageProvider(cpuUsage));
        var options = new DreamineThreadOptions { IntervalMs = 0, UseAdaptiveCpuDelay = true };
        var context = new DreamineThreadCycleContext("worker", 1, 1, null, false, DateTimeOffset.UtcNow);
 
        var delay = policy.GetDelayMs(options, DreamineThreadCoreAssignment.None(), context);
 
        Assert.Equal(expectedDelay, delay);
    }

CoreAssignmentFactories_ExposeExpectedFlags()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.CoreAssignmentFactories_ExposeExpectedFlags ( )

inline

Core Assignment Factories Expose Expected Flags 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 136 번째 라인에서 정의되었습니다.

    {
        Assert.False(DreamineThreadCoreAssignment.None().UseAffinity);
        Assert.True(DreamineThreadCoreAssignment.Dedicated(2, true).IsDedicatedWorker);
        Assert.True(DreamineThreadCoreAssignment.Overflow().IsOverflowPolling);
        Assert.True(new DreamineThreadingOptions().RegisterWindowsServices);
    }

FixedAndOverflowPolicies_ReturnExpectedDelays()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.FixedAndOverflowPolicies_ReturnExpectedDelays ( )

inline

Fixed And Overflow Policies Return Expected Delays 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 77 번째 라인에서 정의되었습니다.

    {
        var options = new DreamineThreadOptions { IntervalMs = 25, OverflowPollingIntervalMs = 80 };
        var context = new DreamineThreadCycleContext("worker", 1, 1, null, false, DateTimeOffset.UtcNow);
 
        Assert.Equal(25, new FixedIntervalCyclePolicy().GetDelayMs(options, DreamineThreadCoreAssignment.None(), context));
        Assert.Equal(80, new FixedIntervalCyclePolicy().GetDelayMs(options, DreamineThreadCoreAssignment.Overflow(), context));
        Assert.Equal(80, new OverflowPollingPolicy().GetDelayMs(options, DreamineThreadCoreAssignment.None(), context));
    }

ThreadingRegistration_UsesFixedPolicyWhenCpuUsageProviderIsMissing()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.ThreadingRegistration_UsesFixedPolicyWhenCpuUsageProviderIsMissing ( )

inline

Threading Registration Uses Fixed Policy When Cpu Usage Provider Is Missing 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 153 번째 라인에서 정의되었습니다.

    {
        DMContainer.Reset();
 
        try
        {
            DreamineThreadingRegistration.Register(new DreamineThreadingOptions
            {
                UseAdaptiveCpuPolicy = true
            });
 
            Assert.IsType<FixedIntervalCyclePolicy>(
                DMContainer.Resolve<IThreadCyclePolicy>());
            Assert.NotNull(DMContainer.Resolve<IDreamineThreadManager>());
        }
        finally
        {
            DMContainer.Reset();
        }
    }

ThreadJobOptions_NormalizeRepairsInvalidValues()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.ThreadJobOptions_NormalizeRepairsInvalidValues ( )

inline

Thread Job Options Normalize Repairs Invalid Values 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 56 번째 라인에서 정의되었습니다.

    {
        var options = new DreamineThreadJobOptions
        {
            Name = " ",
            IntervalMs = -1
        }.Normalize();
 
        Assert.Equal("DreamineThreadJob", options.Name);
        Assert.Equal(10, options.IntervalMs);
    }

ThreadOptions_NormalizeRepairsInvalidStopTimeout()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.ThreadOptions_NormalizeRepairsInvalidStopTimeout ( )

inline

Thread Options Normalize Repairs Invalid Stop Timeout 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 183 번째 라인에서 정의되었습니다.

    {
        var options = new DreamineThreadOptions
        {
            StopTimeout = TimeSpan.Zero
        }.Normalize();
 
        Assert.Equal(TimeSpan.FromSeconds(2), options.StopTimeout);
    }

ThreadOptions_NormalizeRepairsInvalidValues()

void Dreamine.FullKit.Tests.Threading.ThreadingPolicyTests.ThreadOptions_NormalizeRepairsInvalidValues ( )

inline

Thread Options Normalize Repairs Invalid Values 작업을 수행합니다.

ThreadingPolicyTests.cs 파일의 31 번째 라인에서 정의되었습니다.

    {
        var options = new DreamineThreadOptions
        {
            Name = "",
            IntervalMs = -5,
            AutoThreadsPerCore = 0,
            OverflowPollingIntervalMs = -1
        }.Normalize();
 
        Assert.Equal("DreamineThread", options.Name);
        Assert.Equal(10, options.IntervalMs);
        Assert.Equal(2, options.AutoThreadsPerCore);
        Assert.Equal(100, options.OverflowPollingIntervalMs);
    }

---

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

• ThreadingPolicyTests.cs