【正文】 String getName() { this .name = name。 public wsdl。 public } return } setResult(String result) { void Lock getLock() {}import 。*private String name。private String result = PASS。private Lock lock = new ReentrantLock()。 *//** = wsdl。 * 返回包含節(jié)點名稱、WSDL以及驗證結果的字符串return toString。// Getter amp。return name。public String getWsdl() {}return result。public String[] getDependencies() {}return lock。packageimport CallableNode { static String * 構造方法，傳入節(jié)點的WSDL } * 執(zhí)行針對某個節(jié)點的驗證br/ public Lock lock = null 。 + wsdl)。 (node != (當前沒有其他線程驗證節(jié)點 ] )。 { } finally } else [ ()。 // 從未進行過驗證，這種情況應該只出現(xiàn)在系統(tǒng)啟動初期 } [ private (())。 dest。import 。* public ValidationTask(String wsdl) { public Node call() throws Exception { (當前沒有其他線程驗證節(jié)點 + () + [ + wsdl + ])。 try { // 當前有別的線程正在驗證該節(jié)點，等待結果 // 這時是在做初始化，不應該有沖突發(fā)生 private Node mergeNode(Node src, Node dest) {第50行和第51行，那到鎖后立即釋放，這里只是為了等待驗證結束。 new = ()。 final int put(Object x) ()。 { while ()。 (++putptr == ) putptr = InterruptedException { 0 ) Object x = items[takeptr]。 0 。 x。 { ()。 final Condition notFull final Object[] items = new Object[100]。 ++count。 } finally { try { ()。 } finally {await()方法在調用時當前線程先要獲得對應的鎖，既然我都拿到鎖了，那也就是說驗證已經(jīng)結束了。ValidationService中只是聲明(第17 行)，具體的使用是在上面的ValidationTask中。 service。 。import /** ConcurrentHashMapString, Node()。 this .threadPoolService = threadPoolService。 /** public (wsdl)。 (() (nextRoundNodes)。 private for (!(wsdl)) { nextRoundNodes。 private ArrayListValidationTask(())。 (String wsdl : nodes) { return }import 。* 執(zhí)行驗證的服務類*/public class ValidationService {public static final MapString, Node NODE_MAP = new ConcurrentHashMapString, Node()。 *public void validate(ListString wsdl) {(wsdl)。for (Node node : nodes) {(wsdl)。}return nextRoundNodes。for (String wsdl : nodes) {return tasks。以AtomicInteger為例，提供了代替++ 的getAndIncrement()、incrementAndGet()、getAndDecrement()和 decrementAndGet()方法，還有加減給定值的方法、當前值等于預期值時更新的pareAndSet()方法。packageimport 。import class ListNode ENTRIES static new count new private logger /* Node node0 = new ://node1/check?wsdl )。 Node( NODE2 , Node node3 = new ://node5/check?wsdl )。 Node( NODE6 , ://node8/check?wsdl )。 Node( NODE9 , String[] { (), () })。 String[] { (), () })。 String[] { () })。 String[] { (), () })。 String[] { (), () })。 String[] { (), () })。 ((), node0)。 ((), node4)。 ((), node8)。 (node6)。 /** Node validateNode(String wsdl) { + () + ()。 { ()。 */ getCount() { public (())。 newNode。import 。import 。 count logger Node node0 = new Node(NODE0, ://node0/check?wsdl)。 Node node1 = new Node(NODE1, ://node1/check?wsdl)。 Node node2 = new Node(NODE2, ://node2/check?wsdl)。 Node node3 = new Node(NODE3, ://node3/check?wsdl)。 Node node4 = new Node(NODE4, ://node4/check?wsdl)。 Node node5 = new Node(NODE5, ://node5/check?wsdl)。 Node node6 = new Node(NODE6, ://node6/check?wsdl)。 Node node7 = new Node(NODE7, ://node7/check?wsdl)。 Node node8 = new Node(NODE8, ://node8/check?wsdl)。 Node node9 = new Node(NODE9, ://node9/check?wsdl)。 (new String[] { (), () })。 (new String[] { (), () })。 (new String[] { () })。 (new String[] { (), () })。 (new String[] { (), () })。 (new String[] { (), () })。 (FAILED)。 ((), node0)。 ((), node1)。 ((), node2)。 ((), node3)。 ((), node4)。 ((), node5)。 ((), node6)。 ((), node7)。 ((), node8)。 ((), node9)。 (node0)。 (node6)。 } (500)。 } catch (InterruptedException e) { /** * 克隆一個新的Node對象（未執(zhí)行深度克?。?*/環(huán)境間節(jié)點依賴如下：環(huán)境依賴在運行環(huán)境檢查的主類中，使用了CountDownLatch來等待所有驗證結束，在各個并發(fā)驗證的線程完成任務結束前都會調用countDown()，因為有3個并發(fā)的驗證，所以將計數(shù)器設置為3。如果是順序執(zhí)行，驗證次數(shù)應該是13*4=52，但實際的驗證次數(shù)會少于這個數(shù)字(我這里最近一次執(zhí)行了33次驗證)，因為如果同時有兩個線程要驗證同一節(jié)點時只會做一次驗證。packageimport 。import/*** 模擬執(zhí)行這個環(huán)境的驗證* ValidationStarter private ValidationStarter(ListString entries, ValidationService validationService, this .entries = entries。 */ main(String[] args) { (())。 start = ()。 try } (1000 )。 + ())。 + (stop start) + } public ()。package 。import 。* 模擬執(zhí)行這個環(huán)境的驗證*/public class ValidationStarter implements Runnable { entries。 private ValidationService validationService。 private CountDownLatch /** * 線程池大小為10，初始化執(zhí)行一次，隨后并發(fā)三個驗證 */ start = ()。 (entries)。 (new ValidationStarter(entries, validationService, signal))。 (new ValidationStarter(entries, validationService, signal))。 (new ValidationStarter(entries, validationService, signal))。 try { Override