[計(jì)算機(jī)]實(shí)戰(zhàn)javaconcurrent-在線瀏覽
2024-10-03 16:03本頁(yè)面
【正文】 tLock()。 * 默認(rèn)構(gòu)造方法 public /** */ Node(String name, String wsdl) { this .name = name。 } * 返回包含節(jié)點(diǎn)名稱(chēng)、WSDL以及驗(yàn)證結(jié)果的字符串 Override String toString() { String toString = Node: WSDL: Result: return } Setter String getName() { return } setName(String name) { this .name = name。 public wsdl。 public void } String getResult() { return } setResult(String result) { this .result = result。 public dependencies。 public void } Lock getLock() { return }}import 。/**** author DigitalSonicprivate String name。private String wsdl。private String result = PASS。private String[] dependencies = new String[] {}。private Lock lock = new ReentrantLock()。/** */}/** */ = wsdl。} * 返回包含節(jié)點(diǎn)名稱(chēng)、WSDL以及驗(yàn)證結(jié)果的字符串Overridereturn toString。}// Getter amp。public String getName() {return name。}public String getWsdl() {return wsdl。}public String getResult() {return result。}public String[] getDependencies() {return dependencies。}public Lock getLock() {return lock。}}Java代碼packageimport 。importimport/*** 執(zhí)行驗(yàn)證的任務(wù)類(lèi)* ValidationTask CallableNode { private static String * 構(gòu)造方法，傳入節(jié)點(diǎn)的WSDL public } * 執(zhí)行針對(duì)某個(gè)節(jié)點(diǎn)的驗(yàn)證br/ */ public throws Lock lock = null 。 + wsdl)。 (node != if (當(dāng)前沒(méi)有其他線程驗(yàn)證節(jié)點(diǎn) [ ] )。 { Node result = (wsdl)。 } finally } } else (當(dāng)前有別的線程正在驗(yàn)證節(jié)點(diǎn) [ ]，等待結(jié)果 )。 ()。 { // 從未進(jìn)行過(guò)驗(yàn)證，這種情況應(yīng)該只出現(xiàn)在系統(tǒng)啟動(dòng)初期 (首次驗(yàn)證節(jié)點(diǎn)： node = (wsdl)。 } (節(jié)點(diǎn) [ ]驗(yàn)證結(jié)束，驗(yàn)證結(jié)果： return } * 將src的內(nèi)容合并進(jìn)dest節(jié)點(diǎn)中，不進(jìn)行深度拷貝 private (())。 (())。 dest。}import 。import 。/**** author DigitalSonic private static Logger logger = (ValidationTask)。 private String public ValidationTask(String wsdl) { /** * 執(zhí)行針對(duì)某個(gè)節(jié)點(diǎn)的驗(yàn)證br/ * 如果正有別的線程在執(zhí)行同一節(jié)點(diǎn)的驗(yàn)證則等待其結(jié)果，不重復(fù)執(zhí)行驗(yàn)證 */ public Node call() throws Exception { lock = ()。 if (()) { (當(dāng)前沒(méi)有其他線程驗(yàn)證節(jié)點(diǎn) + () + [ + wsdl + ])。 try { ()。 } // 當(dāng)前有別的線程正在驗(yàn)證該節(jié)點(diǎn)，等待結(jié)果 } else { // 這時(shí)是在做初始化，不應(yīng)該有沖突發(fā)生 (節(jié)點(diǎn) + () + [ + wsdl + ]驗(yàn)證結(jié)束，驗(yàn)證結(jié)果： + ())。 return node。 } private Node mergeNode(Node src, Node dest) {第50行和第51行，那到鎖后立即釋放，這里只是為了等待驗(yàn)證結(jié)束。Condition是與Lock結(jié)合使用的，()方法能夠創(chuàng)建與Lock綁定的 Condition實(shí)例。 BoundedBuffer { final new final = ()。 final final new int put(Object x) InterruptedException { ()。 { while ()。 (++putptr == ) putptr = ++count。 } finally } } Object take() InterruptedException { ()。 { while 0 ) Object x = items[takeptr]。 if 0 。 ()。 x。 { ()。 final Condition notFull final Object[] items = new Object[100]。 public void put(Object x) throws InterruptedException { ()。 ()。 ++count。 } finally { ()。 try { while (count == 0) Object x = items[takeptr]。 if (++takeptr == ) takeptr = 0。 ()。 } finally { ()。await()方法在調(diào)用時(shí)當(dāng)前線程先要獲得對(duì)應(yīng)的鎖，既然我都拿到鎖了，那也就是說(shuō)驗(yàn)證已經(jīng)結(jié)束了。CopyOnWriteArrayList是ArrayList的一個(gè)變體，比較適合用在讀取比較頻繁、修改較少的情況下，因?yàn)槊看涡薷亩家獜?fù)制整個(gè)底層數(shù)組。ValidationService中只是聲明(第17 行)，具體的使用是在上面的ValidationTask中。 service。 。import 。import/*** 執(zhí)行驗(yàn)證的服務(wù)類(lèi)* ValidationService { /** */ MapString, Node NODE_MAP = ConcurrentHashMapString, Node()。 private ValidationService(ThreadPoolService threadPoolService) { this .threadPoolService = threadPoolService。 /** * * param wsdl 入口節(jié)點(diǎn)WSDL public void ArrayListString()。 ArrayListString()。 (wsdl)。 (() ListNode nodes = (tasks)。 (nextRoundNodes)。 getNextRoundNodes(nodes, visitedNodes, nextRoundNodes)。 private (Node node : nodes) { for (!(wsdl)) { (wsdl)。 nextRoundNodes。 private ArrayListValidationTask(())。 (String wsdl : nodes) { (new } return }package service。import 。import 。* 執(zhí)行驗(yàn)證的服務(wù)類(lèi)*/public class ValidationService { * 全局節(jié)點(diǎn)表public static final MapString, Node NODE_MAP = new ConcurrentHashMapString, Node()。private ThreadPoolService threadPoolService。/** * * param wsdl 入口節(jié)點(diǎn)WSDLpublic void validate(ListString wsdl) {ListString visitedNodes = new ArrayListString()。(wsdl)。ListValidationTask tasks = getTasks(nextRoundNodes)。ListNode nodes = (tasks)。(nextRoundNodes)。()。getNextRoundNodes(nodes, visitedNodes, nextRoundNodes)。}ListString visitedNodes, ListString nextRoundNodes) {for (Node node : nodes) {(wsdl)。}}return nextRoundNodes。}for (String wsdl : nodes) {}return tasks。}}AtomicInteger對(duì)變量的讀寫(xiě)操作都是原子操作（除了long或者double的變量），但像數(shù)值類(lèi)型的++ 操作不是原子操作，像i++中包含了獲得i的原始值、加寫(xiě)回i、返回原始值，在進(jìn)行類(lèi)似i++這樣的操作時(shí)如果不進(jìn)行同步問(wèn)題就大了。以AtomicInteger為例，提供了代替++ 的getAndIncrement()、incrementAndGet()、getAndDecrement()和 decrementAndGet()方法，還有加減給定值的方法、當(dāng)前值等于預(yù)期值時(shí)更新的pareAnd
黨政相關(guān)相關(guān)推薦
鄂ICP備17016276號(hào)-1