假設我有兩個線程和一個共享C++ 11條件變量。 如果thread1調用notify並在那個thread2調用等待之後會發生什麼? 將永久thread2塊,否則它將繼續它的工作由於thread1的通知調用?如果我呼叫等待通知條件變量,會發生什麼
編輯:
enum bcLockOperation
{
bcLockOperation_Light = -1,
bcLockOperation_Medium = 50,
bcLockOperation_Heavy = 1
}
class BC_COREDLL_EXP bcCustomMutex
{
private:
bcCustomMutex(const bcCustomMutex&);
bcCustomMutex& operator=(const bcCustomMutex&);
protected:
bcAtomic<int> mFlag;
bcMutex mMutex;
bcConditionVariable mCond;
public:
bcCustomMutex() { bcAtomicOperation::bcAtomicInit(mFlag, 0); };
~bcCustomMutex() {};
/*bcMutex(const bcMutex& pOther) = delete;
bcMutex& operator=(const bcMutex& pOther) = delete;*/
bcInline void lock(bcLockOperation pLockOperation = bcLockOperation_Medium)
{
bcINT32 lNewLoopCount = static_cast<bcINT32>(pLockOperation);
bcINT32 lLoopCounter = 0;
bcINT32 lExpected = 0;
bcINT32 lLoopCount = bcAtomicOperation::bcAtomicLoad(mFlag, bcMemoryOrder_Relaxed);
while (true)
{
while(bcAtomicOperation::bcAtomicLoad(mFlag, bcMemoryOrder_Relaxed) != 0 &&
lLoopCounter != lLoopCount)
++lLoopCounter;
bcAtomicOperation::bcAtomicCompareExchangeStrong(
mFlag,
&lExpected,
lNewLoopCount,
bcMemoryOrder_Acquire,
bcMemoryOrder_Relaxed);
if(lExpected == 0)
{
//mMutex.lock();
return;
}
else if(lLoopCounter == lLoopCount)
{
bcLockGuard<bcMutex> lGuard(mMutex);
mCond.wait(mMutex);
}
else
continue;
}
};
bcInline void UnLock()
{
bcAtomicOperation::bcAtomicStore(mFlag, 0, bcMemoryOrder_Relaxed);
bcUniqueLock<bcMutex> lGuard(mMutex);
mCond.notifyOne();
};
bcInline bcBOOL TryLock()
{
};
};
我想寫一個自定義的互斥使得每個線程都可以提供表示操作的當前線程要執行復雜的參數。 如果操作的複雜度較低,其他線程將像循環鎖一樣處於循環狀態,但如果操作的複雜度爲中等,則每個線程將迭代50次,然後通過條件變量休眠,如果操作非常複雜,則其他線程會直接睡覺。
現在假設線程1個鎖定這個互斥及線程無二由於等待其循環計數器達到其最終和右鎖定條件變量的互斥體之前,線程1調用條件變量通知。現在thread2會睡眠,直到另一個線程鎖定自定義互斥鎖,然後調用它解鎖。
我新的多線程和我想學習。我知道我的類可能包含錯誤或者可能是完全錯誤的,但是有什麼方法可以糾正這個問題或者寫一個這樣的互斥體的好算法。
另一個問題是:是我的原子操作正確排序?
你可以自己嘗試,對吧? –
是的,你是對的!但我的筆記本電腦有問題,我正在修理它。現在我正在考慮我的問題,直到我可以編寫代碼。對不起 – MRB
沒有「通知條件變量」這樣的事情。瞭解條件變量最重要的是它們是無狀態的。 –