如何停止“黑匣子”操作？

Question

我正在使用一个异步委托，它调用一个将 xml 文件加载到 XPathDocument 中的方法。如果 xml 太大而无法放入内存，则它永远不会完成加载。如果 xml 文件成功加载到 XPathDocument 中，则以下代码有效。我已经能够使用一个计时器事件来执行 asyncXpath.EndInvoke(result) 语句并且可以结束 CreateDocument 方法，但它不会停止加载 XPathDocument。我的结论是，我唯一能做的就是发出 Application.End 语句来终止应用程序。有谁知道如何停止黑盒操作，例如加载 XPathDocument。

delegate bool AsyncXpathQueryCaller(string xmlfile 

bool found = false; 
AsyncXpathQueryCaller asyncXpath = new 
AsyncXpathQueryCaller(CreateDocument); 
IAsyncResult result = asyncXpath.BeginInvoke(xmlfile, null, null); 
while (!result.IsCompleted) 
{ 
result.AsyncWaitHandle.WaitOne(100, false); 

} 
found = asyncXpath.EndInvoke(result);


private bool CreateDocument (string xmlfile)
{
XPathDocument doc = new XPathDocument(xmlfile);
}

Answer 1

在尝试加载它并检查大小之前使用FileInfo 怎么样？如果它太大，请跳过它。

类似这样的：

FileInfo fi = new FileInfo(xmlfile);
if(fi.Length < /*some huge number*/)
{
  //load the file
}

Answer 2

您可以声明一个 FileStream 并将其提供给构造函数，但在此之前，请查看其 Length 属性，如果它太长，则返回一个错误。

Answer 3

正如 Abe Miessler 所建议的，在尝试将文件加载到 XPathDocument 之前检查文件大小是明智的。

如何决定应该是什么限制？

没有确切的规则，但我听说人们应该将文件大小乘以 5，然后结果接近 XmlDocument 加载/解析文本所需的内存。

Answer 4

编辑：我刚刚意识到KeithS 已经接近一个好的答案。基本思想是你调用XPathDocument constructor，它接受一个Stream，它包装了一个FileStream。传递给它的对象应该实现Read(byte[], int, int) 函数来调用包装好的FileStream 的Read 函数，或者如果操作超时则抛出异常。这是一个代码示例：

class XmlStream : FileStream
{
    DateTime deadline;

    public XmlStream(string filename, TimeSpan timeout)
           : base(filename, FileMode.Open)
    {
        deadline = DateTime.UtcNow + timeout;
    }

    public override int Read(byte[] array, int offset, int count)
    {
        if (DateTime.UtcNow > deadline)
            throw new TimeoutException();
        return base.Read(array, offset, count);
    }
}

这里有一些代码读入document，但在 1 秒后超时：

    bool found = true;
    using(var stream = new XmlStream(document, TimeSpan.FromSeconds(1)))
    try
    {
        xpath = new XPathDocument(stream);
    }
    catch (TimeoutException)
    {
        found = false;
    }

如果您创建一个单独的线程而不是执行BeginInvoke，您可以在计时器计时（或有人单击“取消”）时中止线程。虽然通常不建议中止线程，因为它可能持有锁或全局数据处于不一致状态，但在这种情况下应该没问题，因为您的线程不会持有锁或访问全局数据。

以下是此方法的代码，与上一个示例的作用相同：

    bool found = false;
    thread = new Thread(() =>
    {
        xpath = new XPathDocument(document);
        found = true;
    });
    thread.Start();
    thread.Join(TimeSpan.FromSeconds(1));
    thread.Abort();

如果您对在自己的应用程序域中中止线程感到不舒服，您可以在另一个应用程序域中创建文档，如果时间过长，可以调用AppDomain.Unload。这将需要一些编组，但可能不会有太多开销。

能够杀死一个进程的最终方法是在一个单独的进程中运行它并使用某种远程接口来访问它。不过，这可能比其他选项更混乱，因为您必须担心查找可执行文件、传递参数、某些用户终止它等等。