0

我使用 WIC 制作了一个编码器。然后我尝试在最耗时的部分使用线程。这是

/*Encodes a bitmap source*/
hr = piBitmapFrame->WriteSource(
    piBitmapSrc,    /*bitmap source*/
    rc              /*area which need to be wrote*/
    );

piBitmapSrc → WICBitmap

rc → WICRect，矩形区域做的工作

这就是我尝试的方式。

HRESULT writeSrc(
    IWICBitmapFrameEncode *piBitmapFrame,
    IWICBitmap *piBitmapSrc,
    WICRect *rc
    )
{
    /*Encodes a bitmap source*/
    hr = piBitmapFrame->WriteSource(
        piBitmapSrc,    /*bitmap source*/
        rc              /*area which need to be wrote*/
        );

    return hr;
}

然后我这样称呼它

const int numberOfThreads = 4;
std::thread t[numberOfThreads];
int ht = (lHeight / numberOfThreads);

WICRect rc;
rc.X = 0;
rc.Height = ht;
rc.Width = lWidth;

rc.Y = 0;
t[0] = std::thread(writeSrc, piBitmapFrame, piBitmapSrc, &rc);     

rc.Y += ht;
t[1] = std::thread(writeSrc, piBitmapFrame, piBitmapSrc, &rc);

rc.Y += ht;
t[2] = std::thread(writeSrc, piBitmapFrame, piBitmapSrc, &rc);

rc.Y += ht;
rc.Height = (lHeight - (3*ht));
t[3] = std::thread(writeSrc, piBitmapFrame, piBitmapSrc, &rc);

t[0].join();
t[1].join();
t[2].join();
t[3].join();

问题是，piBitmapFrame->WriteSource()调用了 4 次，但只有 1 次返回 S_OK。其他 3 个返回以下错误代码

WINCODEC_ERR_STREAMWRITE

或者

WINCODEC_ERR_CODECTOOMANYSCANLINES

这是为什么。以及我如何正确使用线程来做到这一点

4

1 回答 1

2

您可能希望更多地研究线程。线程共享全局数据和资源。在您的示例中，您在所有四个线程中共享 piBitMapFrame 和 WICRect 结构。

考虑到 WICRect 结构，您实际上是在分派线程时修改其中的数据。该数据一旦修改，将对所有正在运行的线程可见。所有线程都在引用您声明的单个 WICRect，如果他们检查同一个变量两次 - 他们可能会发现它不同。

我不熟悉这个库，但您应该检查 WriteSource 是否是线程安全调用。piBitmapFrame 是否包含可能通过调用 WriteSource 修改的数据？回想上面的 WICRect 示例，WriteSource 可能无法很好地处理调用中途更改的内部数据。

一个例子：

该程序尝试在两个执行线程中打印到标准输出，而没有任何关于谁在何时写入的同步。这不会崩溃，cout 是线程安全的，但它不会产生您可能期望的输出。输出将是两个线程在标准输出缓冲区中交错字符。

#include <iostream>
#include <thread>

void say_hello(){

    /* no locking to prevent stdout contention */
    for ( int i = 0; i < 10; i++){
        std::cout << "Hello from thread " << std::this_thread::get_id() << "!!!" << std::endl;
    }
}

int main(){

    int i;
    // create our thread 
    std::thread ct1(say_hello);

    // say hello ourselves 
    say_hello();

    // wait for thread ct1 to finish execution.
    ct1.join();
    return i;
}

示例输出：

HHeelllloo  ffrroomm  tthhrreeaadd  00xx170fcf5fd78b000007!3!0!0
!!H!e
llHoe lflroo mf rtohmr etahdr e0axd1 00cx57df8f0f070b!0!0!7
30H0e!l!l!o
 fHreolml ot hfrreoamd  t0hxr1e0acd5 d08x070f0f!f!7!b
00H7e3l0l0o! !f!r
omH etlhlroe afdr o0mx 1t0hcr5eda8d0 000x!7!f!f
f7Hbe0l0l7o3 0f0r!o!m! 
thHreelaldo  0fxr1o0mc 5tdh8r0e0a0d! !0!x
7fHfefl7lbo0 0f7r3o0m0 !t!h!r
eaHde l0lxo1 0fcr5odm8 0t0h0r!e!a!d
 0Hxe7lflfof 7fbr0o0m7 3t0h0r!e!a!d
 0Hxe1l0lco5 df8r0o0m0 !t!h!r
eaHde l0lxo7 fffrfo7mb 0t0h7r3e0a0d! !0!x
10Hce5ldl8o0 0f0r!o!m! 
thHreelaldo  0fxr7ofmf ft7hbr0e0a7d3 000x!1!0!c
5dH8e0l0l0o! !f!r
omH etlhlroe afdr o0mx 7tfhfrfe7abd0 007x31000c!5!d!8
00H0e!l!l!o
 from thread 0x7fff7b007300!!!
于 2015-06-02T03:03:37.290 回答