8

以下代码创建一个新线程，首先充当命名管道客户端以发送参数，然后充当服务器以检索结果。之后，它在另一个 AppDomain 中执行一个函数，充当命名管道服务器，然后作为客户端将结果发回。

public OrderPrice DoAction()
{
  Task<OrderPrice> t = Task<OrderPrice>.Factory.StartNew(NamedPipeClient, parameters);

  if (domain == null)
  {
    domain = AppDomain.CreateDomain(DOMAINNAME);
  }
  domain.DoCallBack(AppDomainCallback);

  return t.Result;
}

static OrderPrice NamedPipeClient(object parameters) {
  OrderPrice price = null;

  using (NamedPipeClientStream stream = new NamedPipeClientStream(PIPE_TO)) {
    stream.Connect();
    SerializeToStream(stream, parameters);
  }

  using (NamedPipeServerStream stream = new NamedPipeServerStream(PIPE_BACK)) {
    stream.WaitForConnection();

    price = (OrderPrice)DeserializeFromStream(stream);
  }

  return price;
}

void AppDomainCallback() {
  OrderPrice price = null;

  using (NamedPipeServerStream stream = new NamedPipeServerStream(PIPE_TO)) {
    stream.WaitForConnection();

    List<object> parameters = (List<object>)DeserializeFromStream(stream);

    if (mi != null)
      price = (OrderPrice)mi.Invoke(action, parameters.ToArray());
}

  using (NamedPipeClientStream stream = new NamedPipeClientStream(PIPE_BACK)) {
    stream.Connect();
    SerializeToStream(stream, price);
  }
}

该代码平均每秒调用一次，并且可以正常工作 7 多个小时。但是在某些时候“system.io.ioexception 所有管道实例都很忙”被抛出，之后它们将不再重新连接。在这里浏览似乎可能是因为没有正确处理管道对象，但我想这一切都很好，因为它们在 using 语句中。有谁知道这里可能出了什么问题？该代码在 Windows Server 2008 上运行的 .NET 4.0 中。

4

1 回答 1

2

听起来它应该是一个mutex而不是一个简单的锁

锁、互斥、信号量……有什么区别？

至于偶尔的停止，可能是饥饿或僵局。

这是关于可能发生的事情的摘要的很好的阅读材料

http://en.wikipedia.org/wiki/Dining_philosophers_problem

于 2013-08-27T13:31:25.307 回答