发送消息不工作
SendMessage is not working
我正在尝试构建一个 dll(具有 Clr 风格)来为 windows 应用程序提供盘中股票报价。 dll 由股票应用程序加载,然后其导出函数之一将启动 downloader/producer 以获取数据。在第二步中,一旦dll 接收到数据,updater/consumer 将通过SendMessage 通知股票应用程序。
我已经通过多种方式测试了下载部分是否按预期工作(有或没有线程支持)所以获取数据没有问题。在单次迭代情况下(下面的测试 1),在快照报价可用后,更新程序成功完成其任务并且 windows UI 得到更新。现在为了不断获得新的报价,我将下载器和更新器函数调用放在一个循环中(下面的 test2)。这一次,下载器连续工作,但更新器中的 SendMessage 挂在那里,留下 windows UI 未更新,直到它退出循环。
这里是测试代码和更新程序代码(让我们把下载器放在一边,因为我们知道它正在工作):
// test1: single iteration, sequential, simple insert only
// result: will update the stock app after quote download
void test1(HWND hwnd, UINT Msg)
{
producer->DownloadStocks();
prepareData(hwnd, Msg, 100);
}
// test2: one iteration of insert followed by updates upon quote download
// result: will update the stock app ONLY after it is out of the while loop
// update in test1 is blocked, too.
void test2(HWND hwnd, UINT Msg)
{
test1(hwnd, Msg);
int i = 0;
while (i<10)
{
producer->DownloadStocks();
prepareData(hwnd, Msg, 100);
i++;
}
}
void prepareData(HWND hwnd, UINT Msg, int timeout)
{
DateTime origin = DateTime(1970, 1, 1, 0, 0, 0, 0);
RCV_DATA rcv_data;
float vv = 0;
rcv_data.m_bDISK = FALSE;
rcv_data.m_nPacketNum = 1;
rcv_data.m_wDataType = RCV_REPORT;
RCV_REPORT_STRUCTEx data;
data.m_fBuyPrice[1] = 0;
data.m_fBuyVolume[1] = 0;
......
data.m_wMarket = (WORD)NQ_MARKET_EX;
while (consumer->received_data())
{
Console::WriteLine("*********************************");
while (consumer->NextRow())
{
sprintf(data.m_szLabel, "%s", consumer->GetValue("symbol"));
.......
data.m_fSellPrice[0] = getVal("ask");
data.m_fSellVolume[0] = getVal("asksize");
rcv_data.m_pReport = &data;
printf("\nsending update for %s", data.m_szLabel);
SendMessage(hwnd, Msg, (WPARAM)RCV_REPORT, (LPARAM)&rcv_data);
}
}
}
我知道 SendMessage 处于同步模式。是被什么东西阻塞了还是消息处理速度太慢了?我该怎么做才能解决这个问题?我应该考虑为下载器和更新器使用线程吗?任何帮助将不胜感激。
'while' 循环和该循环中的调用函数正在占用 CPU。
建议在 while 循环的每次迭代中主动释放 CPU。
也许通过调用 nsleep()
由于您已经通过 SendMessage
将数据发送到 UI 线程,您也可以将 WM_PAINT
事件发送到 window。您可以使用 UpdateWindow or InvalidateRect 执行此操作。这会导致视图在您更新后刷新。
跨线程重绘事件在这里用一些代码解释:redraw-from-another-thread
您需要保持 UI 线程始终空闲以供用户交互。
因此,在后台线程中执行阻塞工作(如下载)。 std::thread可以跨平台工作,如果可以使用c++11
.
我正在尝试构建一个 dll(具有 Clr 风格)来为 windows 应用程序提供盘中股票报价。 dll 由股票应用程序加载,然后其导出函数之一将启动 downloader/producer 以获取数据。在第二步中,一旦dll 接收到数据,updater/consumer 将通过SendMessage 通知股票应用程序。
我已经通过多种方式测试了下载部分是否按预期工作(有或没有线程支持)所以获取数据没有问题。在单次迭代情况下(下面的测试 1),在快照报价可用后,更新程序成功完成其任务并且 windows UI 得到更新。现在为了不断获得新的报价,我将下载器和更新器函数调用放在一个循环中(下面的 test2)。这一次,下载器连续工作,但更新器中的 SendMessage 挂在那里,留下 windows UI 未更新,直到它退出循环。
这里是测试代码和更新程序代码(让我们把下载器放在一边,因为我们知道它正在工作):
// test1: single iteration, sequential, simple insert only
// result: will update the stock app after quote download
void test1(HWND hwnd, UINT Msg)
{
producer->DownloadStocks();
prepareData(hwnd, Msg, 100);
}
// test2: one iteration of insert followed by updates upon quote download
// result: will update the stock app ONLY after it is out of the while loop
// update in test1 is blocked, too.
void test2(HWND hwnd, UINT Msg)
{
test1(hwnd, Msg);
int i = 0;
while (i<10)
{
producer->DownloadStocks();
prepareData(hwnd, Msg, 100);
i++;
}
}
void prepareData(HWND hwnd, UINT Msg, int timeout)
{
DateTime origin = DateTime(1970, 1, 1, 0, 0, 0, 0);
RCV_DATA rcv_data;
float vv = 0;
rcv_data.m_bDISK = FALSE;
rcv_data.m_nPacketNum = 1;
rcv_data.m_wDataType = RCV_REPORT;
RCV_REPORT_STRUCTEx data;
data.m_fBuyPrice[1] = 0;
data.m_fBuyVolume[1] = 0;
......
data.m_wMarket = (WORD)NQ_MARKET_EX;
while (consumer->received_data())
{
Console::WriteLine("*********************************");
while (consumer->NextRow())
{
sprintf(data.m_szLabel, "%s", consumer->GetValue("symbol"));
.......
data.m_fSellPrice[0] = getVal("ask");
data.m_fSellVolume[0] = getVal("asksize");
rcv_data.m_pReport = &data;
printf("\nsending update for %s", data.m_szLabel);
SendMessage(hwnd, Msg, (WPARAM)RCV_REPORT, (LPARAM)&rcv_data);
}
}
}
我知道 SendMessage 处于同步模式。是被什么东西阻塞了还是消息处理速度太慢了?我该怎么做才能解决这个问题?我应该考虑为下载器和更新器使用线程吗?任何帮助将不胜感激。
'while' 循环和该循环中的调用函数正在占用 CPU。
建议在 while 循环的每次迭代中主动释放 CPU。
也许通过调用 nsleep()
由于您已经通过 SendMessage
将数据发送到 UI 线程,您也可以将 WM_PAINT
事件发送到 window。您可以使用 UpdateWindow or InvalidateRect 执行此操作。这会导致视图在您更新后刷新。
跨线程重绘事件在这里用一些代码解释:redraw-from-another-thread
您需要保持 UI 线程始终空闲以供用户交互。
因此,在后台线程中执行阻塞工作(如下载)。 std::thread可以跨平台工作,如果可以使用c++11
.