java 防并发_并发：如何防止两个不同类中的两个方法同时运行？
我有一個(gè)用例，我必須防止兩個(gè)不同的類(lèi)中的兩個(gè)不同的方法同時(shí)運(yùn)行，即如果類(lèi)A有方法X而類(lèi)B有方法Y，我必須確保當(dāng)methodX被執(zhí)行時(shí)，我在methodX完成之前，不應(yīng)允許方法Y執(zhí)行或阻止執(zhí)行 .
class A{
@Scheduled
methodX(){
}
}
class B{
methodY(){}
}
一點(diǎn)背景，這里 methodX 是一個(gè)調(diào)度進(jìn)程，負(fù)責(zé)從遠(yuǎn)程數(shù)據(jù)庫(kù)讀取數(shù)據(jù)，轉(zhuǎn)換，做一些映射并將其存儲(chǔ)在本地?cái)?shù)據(jù)庫(kù)中 .
methodY 是一個(gè)通用實(shí)現(xiàn)(可以由REST調(diào)用或其他調(diào)度進(jìn)程觸發(fā))，它從不同的源讀取數(shù)據(jù)，其中一個(gè)源是 methodX 存儲(chǔ)的數(shù)據(jù)，讀取后也會(huì)執(zhí)行一些映射并將數(shù)據(jù)發(fā)送到另一個(gè)系統(tǒng) .
因?yàn)槲冶仨氃趦蓚€(gè)不同的類(lèi)中同步兩個(gè)不同的方法，所以synchronized關(guān)鍵字或塊不是正確的解決方案 .
我在方法X和方法Y中使用了共享計(jì)數(shù)信號(hào)量，即
class A{
@Scheduled
methodX(){
if(sharedSemaphore.tryAcquire()){
// read data, do mappings etc.
...
...
sharedSemaphore.release();
}
}
}
class B{
methodY(){
if(sharedSemaphore.tryAcquire()){
...
...
...
sharedSemaphore.release();
}
}
}
上面的代碼示例只是實(shí)際實(shí)現(xiàn)的一小部分，有沒(méi)有更好的方法來(lái)做到這一點(diǎn)？信號(hào)量是否是一個(gè)在這里使用的正確的并發(fā)原語(yǔ)？如何確保兩個(gè)不同類(lèi)中的兩個(gè)不同方法不能同時(shí)執(zhí)行？
總結(jié)
以上是生活随笔為你收集整理的java 防并发_并发：如何防止两个不同类中的两个方法同时运行？的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： wifi断流怎么解决
- 下一篇： java 时间段内月份_java获取某段