-2

我有以下方法：

while (TryCount < 2)
{
    Lock.Try<object>(inCommandObj.Connection, _timeout, delegate(DataSet ds)
    {
        dataAdapter = new OdbcDataAdapter(inCommandObj);
        returningObj = dataAdapter.Fill(ds);
        done = true;
        return returningObj;
    });

    if (done)
        break;

    inCommandObj.Cancel();
}

您可以看到我试图将一个 DataSet 传递给这个匿名方法，但它不喜欢它？我怎样才能做到这一点？

最好的祝福

编辑 1：现在的异常消息是：Delegate 'System.Func' 不接受 1 个参数

编辑 2：在这种情况下，我需要使用 dataAdapter.Fill 方法填充现有数据集。这必须使用锁（带 timout）来完成，因为会有很多线程运行此方法。如果锁定超时，我需要取消当前已冻结的 MySQL 命令，然后尝试发送新命令（1 次）。

编辑 3：这就是锁类的样子：

public static class Lock
    {
        public static T Try<T>(object objLock, int timeout, Func<T> f)
        {
            if (System.Threading.Monitor.TryEnter(objLock, timeout))
            {
                try
                {
                    return f.Invoke();
                }
                finally
                {
                    System.Threading.Monitor.Exit(objLock);
                }
            }
            return default(T);
        }

        public static void Try(object objLock, int timeout, Action f)
        {
            if (System.Threading.Monitor.TryEnter(objLock, timeout))
            {
                try
                {
                    f.Invoke();
                }
                finally
                {
                    System.Threading.Monitor.Exit(objLock);
                }
            }
        }
    }
4

1 回答 1

3

在这一行：

public static T Try<T>(object objLock, int timeout, Func<T> f)

Func<T>正在寻找一个不带参数并返回 a 的函数T。您正在向它发送一个接受 aDataSet并返回一个对象的委托。

既然您DataSet无论如何都要在您的委托中创建一个新的，只需从委托中删除它DataSet ds，您就应该一切就绪。

实际上，您可以将其简化为：

Lock.Try<object>(inCommandObj.Connection, _timeout, () =>
{
    var ds = new DataSet();
    dataAdapter = new OdbcDataAdapter(inCommandObj);
    returningObj = dataAdapter.Fill(ds);
    done = true;
    return returningObj;
});

如果这不符合您的预期，那么您需要重构Try以采用不同的Func论点，或者考虑完全不同的解决方案。

于 2013-01-09T19:07:09.487 回答