Microsoft MVP성태의 닷넷 이야기
.NET Framework: 2010. C# - ThreadPool.SetMaxThreads 사용법 [링크 복사], [링크+제목 복사],
조회: 7824
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 
(연관된 글이 1개 있습니다.)

C# - ThreadPool.SetMaxThreads 사용법

ThreadPool.SetMaxThreads는 CLR ThreadPool의 최대 생성 수를 제어할 수 있습니다.

그런데, 오랜만에 테스트하려고 사용했더니 동작을 안 합니다. ^^; 일례로 다음과 같이 간단하게 코딩을 했는데요,

internal class Program
{
    static void Main(string[] args)
    {
        ThreadPool.SetMaxThreads(4, 4);

        for (int i = 0; i < 10; i ++)
        {
            int k = i;
            ThreadPool.QueueUserWorkItem((obj) =>
            {
                Console.WriteLine($"{DateTime.Now.Second}: {k}");
                Thread.Sleep(1000 * 60);
            });
        }

        Console.ReadLine();
    }
}

출력 결과가 이렇게 나옵니다.

9: 9
9: 0
9: 5
9: 6
9: 8
9: 4
9: 7
9: 1
9: 2
9: 3

원래는 4개까지 출력되고, 60초가 지나서야 하나씩 실행돼 10개가 나와야 하는데 그냥 9초 대에서 전부 출력이 된 것입니다. 혹시 뭔가 바뀐 것이 있나 검색했더니,

ThreadPool frustrations - Thread creation exceeding SetMaxThreads
; https://stackoverflow.com/questions/11488966/threadpool-frustrations-thread-creation-exceeding-setmaxthreads

MSDN/docs 도움말을 인용하는군요. ^^

ThreadPool.SetMaxThreads(Int32, Int32) Method
; https://learn.microsoft.com/en-us/dotnet/api/system.threading.threadpool.setmaxthreads

You cannot set the maximum number of worker threads or I/O completion threads to a number smaller than the number of processors on the computer.


제 컴퓨터가 24개의 코어니까, 기본적으로 "ThreadPool.SetMaxThreads(24, 24);" 호출부터 시작해야 하는 것입니다.

그런데, 저렇게 하면 "테스트 용도의" 코드가 좀 번거롭게 됩니다. 24개의 출력 결과를 항상 봐야 한다는 것인데요, 다행히 이에 대한 방법이 있습니다. ^^ 해당 문서에 이에 대해서도 나옵니다.

In addition, you cannot set the maximum number of worker threads or I/O completion threads to a number smaller than the corresponding minimum number of worker threads or I/O completion threads. To determine the minimum thread pool size, call the GetMinThreads method.


그러니까 결국 GetMinThreads의 결과를 따라가는 것인데요,

ThreadPool.GetMinThreads(out int minWorkerThreads, out int minIoThreads);
Console.WriteLine($"Worker: {minWorkerThreads}, IO: {minIoThreads}");

// 24개 코어를 가진 시스템에서,
// 출력 결과: Worker: 24, IO: 24

따라서, SetMinThreads 메서드를 이용해 이를 조절하면 됩니다. 이를 반영해 다시 코딩을 하고,

internal class Program
{
    static void Main(string[] args)
    {
        ThreadPool.SetMinThreads(4, 4);

        ThreadPool.SetMaxThreads(4, 4);

        for (int i = 0; i < 10; i ++)
        {
            int k = i;
            ThreadPool.QueueUserWorkItem((obj) =>
            {
                Console.WriteLine($"{DateTime.Now.Second}: {k}");
                Thread.Sleep(1000 * 60);
            });
        }

        Console.ReadLine();
    }
}

실행하면 이런 결과가 나옵니다.

23: 0
23: 1
23: 2
...[60초 후부터 출력]...

위의 경우 4개가 아닌, 3개의 출력으로 동시 실행을 보이는데요, ThreadPool은 닷넷 응용 프로그램 내부에서 전반적으로 사용되므로 1개는 다른 것에 의해 점유되었을 것입니다.




참고로, SetMinThreads를 사용해야 하는 경우가, 개인적으로는 예제 테스트 코드를 작성하는 경우 빼고는 없었습니다. 하지만, 종종 다음과 같은 상황에서 쓰면 좋을 때도 있습니다.

ThreadPool.QueueUserWorkItem의 실행 지연
; https://www.sysnet.pe.kr/2/0/1455

WCF 프로그램에서 Task를 이용한 백그라운드 작업 시 클라이언트에 대한 병목현상.
; https://www.sysnet.pe.kr/3/0/1310




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]

[연관 글]






[최초 등록일: ]
[최종 수정일: 3/7/2023]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




... 46  47  48  49  50  51  52  53  54  55  56  57  58  [59]  60  ...
NoWriterDateCnt.TitleFile(s)
12163정성태2/27/202010333.NET Framework: 899. 익명 함수를 가리키는 delegate 필드에 대한 직렬화 문제
12162정성태2/26/202013179디버깅 기술: 166. C#에서 만든 COM 객체를 C/C++로 P/Invoke Interop 시 메모리 누수(Memory Leak) 발생 [6]파일 다운로드2
12161정성태2/26/20209792오류 유형: 597. manifest - The value "x64" of attribute "processorArchitecture" in element "assemblyIdentity" is invalid.
12160정성태2/26/202010488개발 환경 구성: 469. Reg-free COM 개체 사용을 위한 manifest 파일 생성 도구 - COMRegFreeManifest
12159정성태2/26/20208614오류 유형: 596. Visual Studio - The project needs to include ATL support
12158정성태2/25/202010459디버깅 기술: 165. C# - Marshal.GetIUnknownForObject/GetIDispatchForObject 사용 시 메모리 누수(Memory Leak) 발생파일 다운로드1
12157정성태2/25/202010383디버깅 기술: 164. C# - Marshal.GetNativeVariantForObject 사용 시 메모리 누수(Memory Leak) 발생 및 해결 방법파일 다운로드1
12156정성태2/25/20209721오류 유형: 595. LINK : warning LNK4098: defaultlib 'nafxcw.lib' conflicts with use of other libs; use /NODEFAULTLIB:library
12155정성태2/25/20208990오류 유형: 594. Warning NU1701 - This package may not be fully compatible with your project
12154정성태2/25/20208799오류 유형: 593. warning LNK4070: /OUT:... directive in .EXP differs from output filename
12153정성태2/23/202011539.NET Framework: 898. Trampoline을 이용한 후킹의 한계파일 다운로드1
12152정성태2/23/202011283.NET Framework: 897. 실행 시에 메서드 가로채기 - CLR Injection: Runtime Method Replacer 개선 - 세 번째 이야기(Trampoline 후킹)파일 다운로드1
12151정성태2/22/202011766.NET Framework: 896. C# - Win32 API를 Trampoline 기법을 이용해 C# 메서드로 가로채는 방법 - 두 번째 이야기 (원본 함수 호출)파일 다운로드1
12150정성태2/21/202011646.NET Framework: 895. C# - Win32 API를 Trampoline 기법을 이용해 C# 메서드로 가로채는 방법 [1]파일 다운로드1
12149정성태2/20/202011402.NET Framework: 894. eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법 [1]
12148정성태2/19/202012645디버깅 기술: 163. x64 환경에서 구현하는 다양한 Trampoline 기법 [1]
12147정성태2/19/202011285디버깅 기술: 162. x86/x64의 기계어 코드 최대 길이
12146정성태2/18/202011499.NET Framework: 893. eBEST C# XingAPI 래퍼 - 로그인 처리파일 다운로드1
12145정성태2/18/202010725.NET Framework: 892. eBEST C# XingAPI 래퍼 - Sqlite 지원 추가파일 다운로드1
12144정성태2/13/202010756.NET Framework: 891. 실행 시에 메서드 가로채기 - CLR Injection: Runtime Method Replacer 개선 - 두 번째 이야기파일 다운로드1
12143정성태2/13/20208795.NET Framework: 890. 상황별 GetFunctionPointer 반환값 정리 - x64파일 다운로드1
12142정성태2/12/202010544.NET Framework: 889. C# 코드로 접근하는 MethodDesc, MethodTable파일 다운로드1
12141정성태2/10/202010123.NET Framework: 888. C# - ASP.NET Core 웹 응용 프로그램의 출력 가로채기 [2]파일 다운로드1
12140정성태2/10/20209994.NET Framework: 887. C# - ASP.NET 웹 응용 프로그램의 출력 가로채기파일 다운로드1
12139정성태2/9/202011358.NET Framework: 886. C# - Console 응용 프로그램에서 UI 스레드 구현 방법
12138정성태2/9/202014124.NET Framework: 885. C# - 닷넷 응용 프로그램에서 SQLite 사용 [6]파일 다운로드1
... 46  47  48  49  50  51  52  53  54  55  56  57  58  [59]  60  ...