按线程返回值

Question

有这个：

public Item_DataColl invoke_command_READ(string UCPTName)
{
    networkingThread = new Thread(new ParameterizedThreadStart(thread_command_READ));
    networkingThread.Start(new readingThreadParameter(UCPTName));
}
private Item_DataColl thread_command_READ_result(object parameter)
{
    readingThreadParameter p = parameter as readingThreadParameter;
    Item item;
    if (p.UCPT_Name != null)
    {
        Item_DataColl resultSet;
        try
        {
            OnProgressBarUpdate(progressBar.UnknownEnd);
            resultSet = connector.command_READ(p.UCPT_Name);
            readOperationDone(resultSet);
            OnConsoleWriting(string.Format("[READING] Lecture réussie : {0} = {1}", ((Dp_Data)resultSet.Item[0]).UCPTname, ((Dp_Data)resultSet.Item[0]).UCPTvalue[0].Value), ILonConnectorConsoleResultType.RESULT);
            return resultSet; // HERE, I WANT TO RETURN RESULT
        }
        catch (Exception e)
        {
            OnConsoleWriting(e.ToString(), ILonConnectorConsoleResultType.ERROR);
        }
        finally
        {
            OnProgressBarUpdate(progressBar.Invisible);
        }
    }
}

我正在尝试执行 SOAP 请求并发送结果。为了使应用程序"非阻塞"，我使用了 Thread。

肥皂请求运行良好，但我无法在线程结束后发送结果。我将不得不跟踪它，并在线程结束时将结果发送回另一个类。

我该如何执行此操作？

Answer 1

嗯..这个解决方案可以写得更好..但我目前正在使用您已经发布的代码。

方法 - 使用回调(带委托(：

首先 - 在类范围内声明委托

private Action<Item_DataColl> OnResultSetComplete;

第二 - 在调用线程之前为委托分配一些函数

public Item_DataColl invoke_command_READ(string UCPTName)
    {
        OnResultSetComplete = (resukts) =>
        {
             // DO SOMETHING HERE
        };
        networkingThread = new Thread(new ParameterizedThreadStart(thread_command_READ));
        networkingThread.Start(new readingThreadParameter(UCPTName));
    }

最后 - 更改读取结果函数：

private Item_DataColl thread_command_READ_result(object parameter)
    {
        readingThreadParameter p = parameter as readingThreadParameter;
        Item item;
        if (p.UCPT_Name != null)
        {
            Item_DataColl resultSet;
            try
            {
                OnProgressBarUpdate(progressBar.UnknownEnd);
                resultSet = connector.command_READ(p.UCPT_Name);
                readOperationDone(resultSet);
                OnConsoleWriting(string.Format("[READING] Lecture réussie : {0} = {1}", ((Dp_Data)resultSet.Item[0]).UCPTname, ((Dp_Data)resultSet.Item[0]).UCPTvalue[0].Value), ILonConnectorConsoleResultType.RESULT);
                if (OnResultSetComplete != null) OnResultSetComplete(resultSet); 
            }
            catch (Exception e)
            {
                OnConsoleWriting(e.ToString(), ILonConnectorConsoleResultType.ERROR);
            }
            finally
            {
                OnProgressBarUpdate(progressBar.Invisible);
            }
        }
    }