인프런 커뮤니티 질문&답변

안녕하세요.
지금 단계에서는 완벽한 테스트가 어려워서 강사님이 보시기에 어떨지 의견 듣고 싶습니다. Send 과정에서 락을 최소화하고 싶어서 C++ 버전을 조금 차용했습니다.
ProcessSend()에서 RegisterSend()를 호출하는 식으로, 한 번에 하나의 송신만 담당하면 락을 줄일 수 있을 것 같아서요.

public void Send(byte[] sendBuffer)
{
    lock (_lock)
    {
        _sendQueue.Enqueue(sendBuffer);
    }

    if (0 == Interlocked.Exchange(ref _sendRegistered, 1))
        RegisterSend();
}

이렇게 해서 한 번에 하나의 스레드만 접근하게 하구요.

void RegisterSend()
{
    lock (_lock)
    {
        while (0 < _sendQueue.Count)
        {
            byte[] buffer = _sendQueue.Dequeue();
            _pendingList.Add(new ArraySegment<byte>(buffer, 0, buffer.Length));
        }
        _sendEvent.BufferList = _pendingList;
    }

    bool pending = _socket.SendAsync(_sendEvent);
    if (false == pending)
    {
        OnSendCompleted(null, _sendEvent);
    }
}

큐에서 데이터를 가져와 _sendEvent.BufferList에 세팅할 때만 락을 잡습니다.

OnSendCompleted는 전체에 락을 안 잡고 중간에만 락을 잡았습니다.

void OnSendCompleted(object sender, SocketAsyncEventArgs sendEvent)
{
    if (0 < sendEvent.BytesTransferred && SocketError.Success == sendEvent.SocketError)
    {
        try
        {
            Console.WriteLine($"Transferred bytes {sendEvent.BytesTransferred}");

            lock(_lock)
            {
                _sendEvent.BufferList = null;
                _pendingList.Clear();

                if (0 == _sendQueue.Count)
                {
                    Interlocked.Exchange(ref _sendRegistered, 0);
                    return;
                }
            }
                
            RegisterSend();
        }
        catch (Exception e)
        {
            Console.WriteLine($"OnSendCompleted Error {e.Message}");
        }
    }
    else
    {
        Disconnect();
    }
}

답변 부탁드립니다. 감사합니다!