gRPC 클라이언트가 처분하지 않음 채널

Question

gRPC를 사용하여 .net core 2.0 응용 프로그램을 개발 중이며 문제를 발견했습니다. gRPC 클라이언트 클래스의 인스턴스에 대한 참조를 삭제 한 후에 resourses (메모리 및 프로세서)를 사용하는 채널이 여전히 존재합니다. 예제 코드 : 유 예제를 실행하면

public class MyClient : ClientBase 
    { 
     public MyClient(Channel channel) : base(channel) 
     { 
     } 
    } 

    internal class Program 
    { 
     private static void Main(string[] args) 
     { 
      var list = new List<MyClient>(); 
      for (var i = 0; i < 10000; i++) 
      { 
       Console.WriteLine($"Creating {i} instance"); 
       list.Add(new MyClient(new Channel("127.0.0.1:61783", ChannelCredentials.Insecure))); 
      } 

      Console.WriteLine("press enter to list = null"); 
      Console.ReadLine(); 
      list = null; 

      Console.WriteLine("press enter to GC.Collect();"); 
      Console.ReadLine(); 
      GC.Collect(); 

      Console.WriteLine("press enter to exit"); 
      Console.ReadLine(); 
     } 
    } 

, u'll (내 PC에) 10 %가이 응용 프로그램에서 사용하는 것을 알 수있다. 심지어 목록 = null이 및 하는 GC.Collect() 후

내가 생각하는 이유는 Channel.ShutdownAsync()를 호출하지 않는 ClientBase입니다.

그래서 질문은 :

문제를 해결하기 위해 더 나은 방법은 무엇입니까?

p.s. 실제로 나는 클라이언트

Client: Grpc.Core.ClientBase<TDto> 

"프로토콜 버퍼 컴파일러에 의해 생성 된"사용하고 난 명시 적으로 생성 된 클래스에서 종료자를 변경할 수 없습니다

Answer 1

가능한 제안은 클라이언트가 IDisposable를 구현하게 될 것 Dispose 방법 Channel.ShutdownAsync()으로 전화하십시오.

public class MyClass : Client, IDisposable { 
    Channel channel; 
    private bool _isDisposed = false; 
    private readonly object _lock = new object(); 

    public MyClass(Channel channel) 
     : base(channel) { 
     this.channel = channel; 
     this.channelDisposing += onDisposing; 
    } 

    public Channel Channel { get { return channel; } } 

    private event EventHandler channelDisposing = delegate { }; 

    async void onDisposing(object sender, EventArgs e) { 
     await channel.ShutdownAsync(); 
     channel = null; 
    } 

    public void Dispose() { 
     if (!_isDisposed) { 
      Dispose(true); 
      GC.SuppressFinalize(this); 
     } 
    } 

    void Dispose(bool disposing) { 
     // No exception should ever be thrown except in critical scenarios. 
     // Unhandled exceptions during finalization will tear down the process. 
     if (!_isDisposed) { 
      try { 
       if (disposing) { 
        // Acquire a lock on the object while disposing. 
        if (channel != null) { 
         lock (_lock) { 
          if (channel != null) { 
           channelDisposing(this, EventArgs.Empty); 
          } 
         } 
        } 
       } 
      } finally { 
       // Ensure that the flag is set 
       _isDisposed = true; 
      } 
     } 
    } 
} 

이

는이 범위를 벗어날 갈 때 당신을 위해 수행 될 수 있도록 지금 클라이언트에 Dispose를 호출하고 자원을 해제 또는 using에서 그들을 포장 할 수 있습니다.

public class Program { 
    public static void Main(string[] args) { 
     var list = new List<MyClient>(); 
     for (var i = 0; i < 10000; i++) { 
      Console.WriteLine($"Creating {i} instance"); 
      list.Add(new MyClient(new Channel("127.0.0.1:61783", ChannelCredentials.Insecure))); 
     } 

     Console.WriteLine("press enter to dispose clients"); 
     Console.ReadLine(); 
     list.ForEach(c => c.Dispose()); 

     Console.WriteLine("press enter to list = null"); 
     Console.ReadLine(); 
     list = null; 

     Console.WriteLine("press enter to GC.Collect();"); 
     Console.ReadLine(); 
     GC.Collect(); 

     Console.WriteLine("press enter to exit"); 
     Console.ReadLine(); 
    } 
}