Microsoft MVP성태의 닷넷 이야기
.NET Framework: 416. System.Net.Sockets.NetworkStream이 Thread-safe할까? [링크 복사], [링크+제목 복사],
조회: 27654
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

System.Net.Sockets.NetworkStream이 Thread-safe할까?

socket 관련 thread-safe의 마지막 글입니다. ^^

System.Net.Sockets.Socket이 Thread-safe할까?
; https://www.sysnet.pe.kr/2/0/1469

Win32 socket이 Thread-safe할까?
; https://www.sysnet.pe.kr/2/0/1473

이번에는 Socket I/O를 Stream으로 감싼 System.Net.Sockets.NetworkStream 차례입니다. 아래의 문서에 보면,

NetworkStream Class
; https://docs.microsoft.com/en-us/dotnet/api/system.net.sockets.networkstream

NetworkStream 역시 일반 BCL과 마찬가지의 thread-safety 정책이 걸려 있습니다.

Thread Safety: Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.


그래서 지난번 글과 동일하게 테스트를 해보았는데,

static void Main(string[] args)
{
    Thread.Sleep(2000);

    string body = string.Empty;
    StringBuilder sb = new StringBuilder();

    Array.ForEach(Enumerable.Range(0, 10).ToArray(), (elem) => body += elem.ToString());
    for (int i = 0; i < 10000; i++)
    {
        sb.Append(body);
    }

    body = sb.ToString();

    int loopCount = 10000;
    int dot = (loopCount / (80 * 25));

    List<CommonPacket> packets = new List<CommonPacket>();

    using (TcpClient socket = new TcpClient("192.168.0.6", 11200))
    {
        // IPAddress target = IPAddress.Loopback; 
        IPAddress target = IPAddress.Parse("192.168.0.6");
        EndPoint serverEP = new IPEndPoint(target, 11200);

        NetworkStream ns = socket.GetStream();
        int instanceId = 0;

        byte[] instanceIdBuf = BitConverter.GetBytes(instanceId);
        ns.Write(instanceIdBuf, 0, 4);

        for (int i = 0; i < loopCount; i++)
        {
            CommonPacket packet = new CommonPacket(i);
            packet.AddData(body);

            packets.Add(packet);
        }

        List<Thread> threads = new List<Thread>();
        ThreadParam threadParam = new ThreadParam();
        threadParam.Packets = packets;
        threadParam.NetStream = ns;
        threadParam.Dot = dot;

        for (int i = 0; i < 20; i++)
        {
            Thread aThread = new Thread(sendBufferThread);
            aThread.IsBackground = true;
            aThread.Start(threadParam);

            threads.Add(aThread);
        }

        foreach (var item in threads)
        {
            item.Join();
        }

        socket.Close();
        Console.WriteLine("TCP Client socket: Closed");
        Console.WriteLine(loopCount + " times: data sent");
        Console.WriteLine((body.Length / 1024) + "KB / packet");

        Console.WriteLine();
        Console.WriteLine();

        Console.WriteLine("Press any key to exit");
        Console.ReadLine();
    }
}

private static void sendBufferThread(object obj)
{
    ThreadParam threadParam = (ThreadParam)obj;

    while (true)
    {
        CommonPacket packet = null;

        lock (threadParam.Packets)
        {
            if (threadParam.Packets.Count == 0)
            {
                break;
            }

            packet = threadParam.Packets[0];
            threadParam.Packets.RemoveAt(0);
            threadParam.Sent++;

            if (threadParam.Sent % threadParam.Dot == 0)
            {
                Console.Write(".");
            }
        }

        byte[] dataBuf = packet.GetBuffer();
        MustSendBuffer(threadParam.NetStream, dataBuf, dataBuf.Length);
    }
}

private static bool MustSendBuffer(NetworkStream ns, byte[] dataBuf, int mustSend)
{
    ns.Write(dataBuf, 0, mustSend);
    return true;
}

결과는 thread-safe했습니다. 이상하군요. 그런대로 충돌이 날 만한데요. 이에 대해서는 NetworkStream.Write 메서드를 .NET Reflector를 통해 보면 짐작할 수 있습니다.

public override void Write(byte[] buffer, int offset, int size)
{
    bool canWrite = this.CanWrite;
    if (this.m_CleanedUp)
    {
        throw new ObjectDisposedException(base.GetType().FullName);
    }
    if (!canWrite)
    {
        throw new InvalidOperationException(SR.GetString("net_readonlystream"));
    }
    if (buffer == null)
    {
        throw new ArgumentNullException("buffer");
    }
    if ((offset < 0) || (offset > buffer.Length))
    {
        throw new ArgumentOutOfRangeException("offset");
    }
    if ((size < 0) || (size > (buffer.Length - offset)))
    {
        throw new ArgumentOutOfRangeException("size");
    }
    Socket streamSocket = this.m_StreamSocket;
    if (streamSocket == null)
    {
        throw new IOException(SR.GetString("net_io_writefailure", new object[] { SR.GetString("net_io_connectionclosed") }));
    }
    try
    {
        streamSocket.Send(buffer, offset, size, SocketFlags.None);
    }
    catch (Exception exception)
    {
        if (((exception is ThreadAbortException) || (exception is StackOverflowException)) || (exception is OutOfMemoryException))
        {
            throw;
        }
        throw new IOException(SR.GetString("net_io_writefailure", new object[] { exception.Message }), exception);
    }
}

보시는 바와 같이 Write(및 Read) 메서드 안에서 인스턴스 멤버에 대한 조작을 하는 코드가 없습니다. 하부 단의 "Socket streamSocket" 멤버는 Socket 자체가 thread-safe하기 때문에 상관없고!

물론 NetworkStream 타입의 멤버가 thread-safe하지 않다고 되어 있으므로 향후 내부적으로 인스턴스 멤버를 조작하는 코드가 추가되는 경우 오동작을 할 여지가 있습니다. 따라서, 성능에 크게 영향이 없다면 NetworkStream을 사용하는 경우에는 lock을 적절하게 걸어주는 것이 권장됩니다.

(첨부파일은 위의 동작을 테스트한 코드를 담고 있습니다.)




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







[최초 등록일: ]
[최종 수정일: 7/17/2021]

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

비밀번호

댓글 작성자
 




... [121]  122  123  124  125  126  127  128  129  130  131  132  133  134  135  ...
NoWriterDateCnt.TitleFile(s)
10989정성태6/7/201624443.NET Framework: 596. C# - WCF wsDualHttpBinding의 ClientBaseAddress 속성 - 두 번째 이야기
10988정성태6/3/201625630기타: 57. Outlook blocked access to the following potentially unsafe attachments
10987정성태6/2/201626642.NET Framework: 595. XLL 파일에 포함된 .NET 어셈블리를 추출하는 방법
10986정성태6/1/201627546.NET Framework: 594. C# - WCF wsDualHttpBinding의 ClientBaseAddress 속성
10985정성태6/1/201625350오류 유형: 336. An error occurred while ejecting 'DVD RW drive ...'
10984정성태5/31/201631189.NET Framework: 593. C# - wsDualHttpBinding WCF 예제 프로그램파일 다운로드1
10983정성태5/30/201624676VC++: 97. C++ 템플릿 remove_pointer, enable_if, is_pointer 사용 예제파일 다운로드1
10982정성태5/26/201623063오류 유형: 335. SQL Server Management Studio - The database ... is not accessible.
10981정성태5/24/201628954.NET Framework: 592. C# - Lights Out 퍼즐 풀기 [2]파일 다운로드1
10980정성태5/24/201625573VS.NET IDE: 108. Visual Studio 2013/2015를 위한 "Macros for Visual Studio"
10979정성태5/23/201628162.NET Framework: 591. C# - 조합(Combination) 예제 코드 - 두 번째 이야기파일 다운로드1
10978정성태5/23/201627502.NET Framework: 590. C# - 모든 경우의 수를 조합하는 코드 (2)파일 다운로드1
10977정성태5/23/201632383.NET Framework: 589. C# - 모든 경우의 수를 조합하는 코드 (1)파일 다운로드1
10976정성태5/20/201626975Math: 18. C# - 오일러 공식을 이용한 복소수 값의 라디안 회전파일 다운로드1
10975정성태5/20/201627233Math: 17. C# - 복소수 타입의 승수를 지원하는 Power 메서드파일 다운로드1
10974정성태5/20/201627053.NET Framework: 588. C# - OxyPlot 라이브러리로 복소수 표현파일 다운로드1
10973정성태5/20/201631923.NET Framework: 587. C# Plotting 라이브러리 OxyPlot [3]파일 다운로드1
10972정성태5/19/201632360Math: 16. C# - 갈루아 필드 GF(2) 연산 [3]파일 다운로드1
10971정성태5/19/201623681오류 유형: 334. Visual Studio - 빌드 시 경고 warning MSB3884: Could not find rule set file "...". [2]
10970정성태5/19/201629144오류 유형: 333. OxyPlot 라이브러리의 컨트롤을 Toolbox에 등록 시 오류 [2]
10969정성태5/18/201626969.NET Framework: 586. C# - 파일 확장자에 연결된 프로그램을 등록하는 방법 (3) - "Open with" 목록에 등록파일 다운로드1
10968정성태5/18/201623216오류 유형: 332. Visual Studio - 단위 테스트 생성 시 "Design time expression evaluation" 오류 메시지
10967정성태5/12/201628731.NET Framework: 585. C# - 파일 확장자에 연결된 프로그램을 등록하는 방법 (2) - 웹 브라우저가 다운로드 후 자동 실행
10966정성태5/12/201636746.NET Framework: 584. C# - 파일 확장자에 연결된 프로그램을 등록하는 방법 (1) - 기본 [1]파일 다운로드1
10965정성태5/12/201629754디버깅 기술: 81. try/catch로 조용히 사라진 예외를 파악하고 싶다면? [2]
10964정성태5/12/201626917오류 유형: 331. ASP.NET에서 System.BadImageFormatException 예외가 발생하는 경우
... [121]  122  123  124  125  126  127  128  129  130  131  132  133  134  135  ...