浜掓枼鎬т綋鐜板湪綾婚攣鎴栬呭璞￠攣涓婏紝姣忎釜瀵硅薄鑷韓閮藉寘鍚竴涓洃瑙嗗櫒錛岃鐩戣鍣ㄦ槸涓涓瘡嬈″彧鑳借涓涓嚎紼嬫墍鑾峰彇榪涘叆鐨勪復鐣屽尯錛屽彲浠ラ氳繃wait鍜宯otify鏉ラ鍑哄拰鍑嗗叆涓寸晫鍖恒傚彲浠?/font>鐪嬪嚭榪欐槸涓涓敓浜ц?娑堣垂鑰呯殑妯″瀷銆傝孋oncurrent鍖呬腑鐨凩ock涓轟簡鑳藉鑾峰緱鏇村ソ鐨勬ц兘鍜屾洿濂界殑鎵╁睍鎬э紝浠ュ強涓嶄緷璧栦簬鍏抽敭瀛楃殑鍙浠ｇ爜錛岃嚜宸卞疄鐜頒簡榪欐牱涓涓敓浜ф秷璐歸槦鍒楋紝涔?/font>灝辨槸AbstractQueuedSynchronizer錛岃縐頒負AQS鐨勬満鍒躲傛瘡涓狶ock閮藉唴緗簡涓涓狝bstractQueuedSynchronizer銆傞渶瑕佽鏄庣殑鏄疉bstractQueuedSynchronizer鍐呴儴瀹炵幇閲囩敤浜咰AS鏈哄埗錛岄氳繃getState, setState, compareAndSetState璁塊棶鎺у埗涓涓?2bit int鐨勫艦寮忚繘琛屼簰鏂ャ?/font>
閭ｄ箞鍙鎬ф槸濡備綍淇濊瘉鐨勫憿錛?/font>
瀵逛簬鍏抽敭瀛楃殑鍚屾鏈哄埗錛屽叾瀹炲彲瑙佹у氨鏄嚎紼嬪拰涓誨瓨涔嬮棿鐨勫悓姝ユ椂鏈洪棶棰樸傚叡鏈?涓椂闂寸偣闇瑕佹敞鎰忥細
1 鑾峰彇鎴栭噴鏀劇被閿?瀵硅薄閿佺殑鏃跺欍俆hread淇濊瘉reload/flush鍏ㄩ儴鍙樻洿
2 volatile灝辨槸flush on write鎴栬卹eload on read
3 褰撶嚎紼嬮嬈¤闂叡浜彉閲忔椂錛屽彲浠ュ緱鍒版渶鏂扮殑緇撴灉銆?br />
棰樺錛氭墍浠ュ湪鏋勯犳柟娉曚腑鍏竷this鏃跺緢鍗遍櫓鐨勩傜畝鍗曠殑璇達紝灝辨槸鏋勯犳椂涓嶉冭劚浠諱綍鍙橀噺錛屼笉寮鍚柊鐨勭嚎紼嬶紝鍙仛灝佽銆傚叧浜庡畨鍏ㄦ瀯閫狅紝璇峰弬鑰?br />
http://www.ibm.com/developerworks/cn/java/j-jtp0618/#resources
4 綰跨▼緇撴潫鏃訛紝鎵鏈夊彉鏇翠細鍐欏洖涓誨瓨
鍏充簬Concurrent Lock濡備綍瀹炵幇鍙鎬х殑闂錛孌oug Lea澶т緺錛屽彧鍦ㄤ粬鐨勮鏂囦腑鎻愬埌錛屾寜鐓SR133錛孶nsafe鍦╣etState, setState, compareAndSetState鏃朵繚璇佷簡綰跨▼鐨勫彉閲忕殑鍙鎬э紝涓嶉渶瑕侀澶栫殑volatile鏀寔錛岃嚦浜庡叿浣撹繖浜沶ative鍋氫簡鍝簺magic灝變笉寰楄岀煡浜嗭紝鎬諱箣錛屾渶鍚庣殑contract灝辨槸淇濊瘉lock鍖洪棿鐨勫叡浜彉閲忓彲瑙佹с傚紑鍙戝洟闃熻閫兼ヤ簡灝辮繖鏍峰洖絳旓細
There seems to be a real reluctance to explain the dirty details. I think the question was definitely understood on the concurrent interest thread, and the answer is that synchronized and concurrent locking are intended to be interchangable in terms of memory semantics when implemented correctly. The answer to matfud's question seems to be "trust us.”
涓嶈繃榪欎釜鍦版柟鐨勭‘鏄紑鍙戝洟闃熺粰鎴戜滑鐢ㄦ埛榪鋒儜鐨勫湴鏂癸紝鍦ㄥ悓鏍峰簲鐢ㄤ簡CAS鏈哄埗鐨凙tomic綾諱腑錛岄兘鍐呭祵浜唙olatile鍙橀噺錛屼絾鏄啀lock鍧椾腑錛屼粬鍛婅瘔鎴戜滑鍙互淇濊瘉鍙鎬с?/font>
鎰熷叴瓚ｇ殑鍚屽鍙互涓嬮潰鐨勪袱涓猼hread鍜孌oug Lea鐨則hesis錛?br />
http://altair.cs.oswego.edu/pipermail/concurrency-interest/2005-June/001587.html
http://forums.sun.com/thread.jspa?threadID=631014&start=15&tstart=0
http://gee.cs.oswego.edu/dl/papers/aqs.pdf
]]>
鏂囦歡緋葷粺鏃犻潪灝辨槸鏂囦歡鐨勫瓨鍙栧拰緇勭粐緇撴瀯銆?br /> 璁塊棶涓涓枃浠剁郴緇熺殑API涔熷簲璇ユ槸鍐欙紝璇伙紝瀹氫綅鏂規硶錛圥athname?/URI?錛?/p>
FTPClient閽堝鏂囦歡鐨勪繚瀛樺拰鑾峰彇鍚勬彁渚涗簡涓や釜鏂規硶錛屽垎鍒槸錛?br />
public boolean storeFile(String remote, InputStream local)public OutputStream storeFileStream(String remote)public boolean retrieveFile(String remote, OutputStream local)public InputStream retrieveFileStream(String remote)
涓や釜鏂規硶璨屼技鐩稿悓錛屽疄闄呬笉鍚岋紝榪斿洖嫻佺殑閭ｄ釜鍥犱負涓嶈兘椹笂澶勭悊嫻侊紝鎵浠ラ渶瑕佺敤鎴鋒墜宸ヨ皟鐢╟ompletePendingCommand錛岃屽彟涓涓紶閫掓祦榪涘幓鐨勫垯涓嶉渶瑕併傚彲鑳芥湁鍚屽宸茬粡閬囧埌榪囪繖涓棶棰樹簡錛岃鍐欑涓涓枃浠舵椂鎬繪槸姝ｇ‘鐨勶紝褰撶浉鍚孉PI璇誨啓絎簩涓枃浠舵椂錛宐lock浣忎簡銆傝繖鏄洜涓篎TPClient瑕佹眰鍦ㄨ繘琛屾祦鎿嶄綔涔嬪悗鎵цcompletePendingCommand錛屼互紜繚嫻佸鐞嗗畬姣曪紝鍥犱負嫻佸鐞嗕笉鏄嵆鏃剁殑錛屾墍浠ヤ篃娌℃湁鍔炴硶涓嶆墜宸ヨ皟鐢╟ompletePendingCommand銆傞棶棰樻槸寮鍙戣呮妸涓嶈繑鍥炴祦鐨勬柟娉曟湯灝懼姞涓婁簡completePendingCommand錛屽鏋滀笉鐪嬩唬鐮佸彲鑳芥牴鏈笉鐭ラ亾銆?br /> 鏂囨。涓婅錛?br />
* There are a few FTPClient methods that do not complete the * entire sequence of FTP commands to complete a transaction. These * commands require some action by the programmer after the reception * of a positive intermediate command. After the programmer's code * completes its actions, it must call this method to receive * the completion reply from the server and verify the success of the * entire transaction.
浣嗘槸榪欐牱浠嶇劧榪樻槸璁╀漢鏈夌偣鍥版儜錛屼負浠涔堥兘鏄瓨鍌?璇誨彇鐨勬柟娉曪紝鏈夋椂鍊欒璋冪敤completePendingCommand錛屾湁鏃跺欎笉璋冪敤錛熸洿涓ラ噸鐨勯棶棰樻槸completePendingCommand璋冪敤浜唃etReply錛屽鏋滀竴涓懡浠ら氳繃socket stream浼犱簡榪囧幓浣嗘槸娌℃湁getReply錛屽嵆娌℃湁completePendingCommand錛岄偅涔堜笅嬈″彂鍛戒護鏃訛紝灝嗕細鍙楀埌鏈榪斿洖鐮佺殑騫叉壈錛屽緱鍒版棤鏁堢殑鍝嶅簲銆傝屽鏋滃湪completePendingCommand涔嬪悗鍙堣繘琛屼簡涓嬈℃棤杈滅殑completePendingCommand錛岄偅涔堝洜涓篎TP Server涓婃病鏈塕eply浜嗭紝灝變細block銆傛墍浠ompletePendingCommand騫朵笉鏄彲浠ラ殢鎰忔坊鍔犵殑銆?/p>
鐜板湪鍑虹幇浜嗕袱涓棶棰橈細
1 completePendingCommand寰堝鏄撳鍑烘潵鎴栭仐婕?br />
2 鏄懼紡璋冪敤completePendingCommand鏆撮湶浜嗗簳灞傚疄鐜幫紝緇欑敤鎴峰甫鏉ヤ笉渚匡紝鐢ㄦ埛鍙兂瑕両nputStream鎴栬匫utputStream
涓轟簡瑙ｅ喅榪欎釜闂錛屽彲浠ュInputStream榪涜鎵╁睍錛屽緩绔嬩竴涓猂eplyOnCloseInputStream錛屽涓嬶細
private static ReplyOnCloseInputStream extends InputStream{
//
public ReplyOnCloseInputStream(InputStream is, FTPClient c){
//
} // @override public void close(){ if(c.completePendingCommand){ is.close(); }else{ //throw Exception } }
} //return new ReplyOnCloseInputStream(is, client);
榪欐牱灝佽涔嬪悗錛孎TPClient鐨勭敤鎴峰彧闇瑕佹甯稿湪澶勭悊瀹屾祦涔嬪悗鍏抽棴鍗沖彲錛岃屼笉蹇呮毚闇插疄鐜扮粏鑺傘備繚瀛樻枃浠朵篃鍙互鐢ㄧ浉鍚岀殑鏂規硶灝佽OutputStream銆?/p>
1 澶氭牳鍒╃敤
2 涓哄崟涓換鍔″緩妯℃柟渚?
3 寮傛澶勭悊涓嶅悓浜嬩歡錛屼笉蹇呯洸絳?
4 鐜頒唬鐨刄I涔熼渶瑕佸畠
椋庨櫓錛?/strong>
1 鍚屾鍙橀噺鏄撻敊璇?
2 鍥犺祫婧愰檺鍒跺鑷寸嚎紼嬫椿璺冩ч棶棰?
3 鍥?瀵艱嚧鐨勬ц兘闂
鐢ㄩ旓細
妗嗘灦錛孶I錛孊ackend
綰跨▼瀹夊叏鐨勬湰璐ㄦ槸浠涔堬細
騫墮潪鏄嚎紼嬪拰閿侊紝榪欎簺鍙槸鍩虹緇撴瀯錛屾湰璐ㄦ槸濡備綍鎺у埗鍏變韓鍙橀噺璁塊棶鐨勭姸鎬?
浠涔堟槸綰跨▼瀹夊叏錛?/strong>
灝辨槸綰跨▼涔嬮棿鐨勬墽琛?strong>榪樻病鏈?/strong>鍙戠敓閿欒錛屽氨鏄病鏈夊彂鐢熸剰澶?
涓涓嚎紼嬪畨鍏ㄧ殑綾繪湰韜皝瑁呬簡瀵圭被鍐呴儴鏂規硶鍜屽彉閲忕殑寮傛璇鋒眰錛岃皟鐢ㄦ柟鏃犻渶鑰冭檻綰跨▼瀹夊叏闂
鏃犵姸鎬佺殑鍙橀噺鎬繪槸綰跨▼瀹夊叏鐨?
鍘熷瓙鎬э細
瀹屾暣鎵ц鐨勫崟鍏冿紝濡備笉鍔犻攣鎺у埗錛屽垯浼氬彂鐢熺珵鎬佹潯浠訛紝濡備笉鍔犻攣鐨勬噿姹夊崟渚嬫ā寮忥紝鎴栬呭鍚堟搷浣溿?
閿侊紝鍐呭湪閿侊紝閲嶅叆錛?/strong>
鍒╃敤synchronized鍏抽敭瀛楁帶鍒惰闂崟鍏冿紝鍚屼竴綰跨▼鍙互閲嶅叆閿佸唴閮紝閬垮厤浜嗛潰鍚戝璞′駭鐢熺殑闂銆傚悓涓鍙橀噺鐨勬墍鏈夊嚭鐜板満鍚堝簲璇ヤ嬌鐢ㄥ悓涓涓攣鏉ユ帶鍒躲俿ynchronized(lock)銆?
鍗充嬌鎵鏈夋柟娉曢兘鐢╯ynchronized鎺у埗涔熶笉鑳戒繚璇佺嚎紼嬪畨鍏紝瀹冨彲鑳藉湪璋冪敤鏃剁紪紼嬪鍚堟搷浣溿?
媧昏穬鎬у拰鎬ц兘闂錛?/strong>
榪囧ぇ鐨勭矑搴︿細瀵艱嚧榪欎釜闂錛岀敤閿佽繘琛屽紓姝ユ帶鍒訛紝瀵艱嚧浜嗙嚎紼嬬殑欏哄簭鎵ц銆?
綆鍗曞拰鎬ц兘鏄竴瀵圭煕鐩撅紝闇瑕侀傚綋鐨勫彇鑸嶃備笉鑳藉湪娌℃湁鑰冭檻鎴愮啛鐨勬儏鍐典笅錛屼負浜嗘ц兘鍘葷壓鐗茬畝媧佹с?
瑕佸敖閲忛伩鍏嶈楁椂鎿嶄綔錛孖O鍜岀綉緇滄搷浣滀腑浣跨敤閿?
]]>
闂
Store鍖呭惈涓や釜澧炲姞Record鐨勬柟娉曪紝鍗砳nsert鍜宎dd錛屽叾涓殑insert娌℃湁鏇存柊snapshot鎵浠ュ綋閲嶆柊搴旂敤filter鏃訛紝鍗砫ata琚噸鏂板畾涔夋椂錛屽湪data涓嬌鐢╥nsert鏂板鐨勮褰曟槸鏃犳晥鐨勩?
瑙ｅ喅鏂規硶
鐢╝dd涓嶈鐢╥nsert錛屽鏋滅敤insert錛岃寰楁妸鏁版嵁鍐欒繘snapshot: store.snapshot.addAll(records)
]]>
鐩稿悓鐐癸細
閰嶇疆淇℃伅錛歑ML OR 鏁版嵁搴?
鎺т歡鍖栵細
浼樼偣錛?
1 鏄撲簬娣誨姞鍏叡鍔熻兘
2 淇敼閰嶇疆鏁版嵁鐩存帴鐢熸晥
3 浠ｇ爜緇撴瀯娓呮櫚錛屽寮鍙戣呭弸濂?
緙虹偣錛?
1 閲嶇粍鍐呭瓨涓璞＄粨鏋勶紝鎬ц兘娌℃湁浠ｇ爜鐢熸垚濂斤紙浣嗘覆鏌撴椂闂寸浉鍚岋級
2 浠呰兘鎺у埗緇勪歡鑷韓灝佽鐨勯厤緗紝涓嶆敮鎸佷釜鎬у寲淇敼錛屽鏋滈厤緗枃浠朵笉鏀寔鐨勫弬鏁幫紝鍒欐帶浠朵笉鏀寔
3 蹇呴』淇濊瘉姣忎釜鎺т歡涓涓厤緗?
浠ｇ爜鐢熸垚錛?
浼樼偣錛?
1 鎬ц兘杈冨ソ
2 鏄撲簬瀹氬埗鍐呭
3 鍙互鍙厤緗竴涓ā鐗堬紝鐒跺悗鍋氬嚭澶氫釜綆鍗曠殑淇敼
緙虹偣錛?
1 涓嶈兘閽堝澶氫釜欏甸潰鍚屾椂娣誨姞鍏叡鍔熻兘
2 涓氬姟淇敼闇瑕侀噸鏂扮敓鎴愪唬鐮?
3 寮鍙戣呴渶瑕佷慨鏀硅嚜鍔ㄧ敓鎴愮殑浠ｇ爜錛屽茍闇瑕佷簡瑙ｄ竴浜涘簳灞傜殑瀹炵幇緇撴瀯
=====================20091029
浠ｇ爜鐢熸垚騫朵笉鑳芥彁楂樺伐浣滄晥鐜囷紝灝ゅ叾鏄拡瀵瑰鏉傜殑瀵屽鎴風寮鍙?
寮鍙戠粍浠跺彲鎻愭彁渚涗竴縐嶆湁鏁堢殑閫夐」錛屼絾鏄湪榪愯鏁堢巼鍜屽唴瀛樺鐞嗕笂闇瑕佺粏蹇冨鐞?
]]>
var workflowDef = {
start:{
fn:"begin", //瀵瑰簲澶勭悊鏂規硶鍙互鍦ㄥ唴閮ㄥ畾涔夛紝涔熷彲浠ュ湪澶栭儴瀹氫箟
next:["task1","task2"]
},
end:"end",
tasks:[{
id:"task1",
fn:function(){
alert("鎵ц浠誨姟涓");
},
before:function(){
alert("鎵ц浠誨姟涓鍓?/span>");
},
after:function(){
alert("鎵ц浠誨姟涓鍚?/span>");
},
next:["task4","task5"]
},{
id:"task2",
fn:function(){
alert("鎵ц浠誨姟浜?/span>");
},
before:function(){
alert("鎵ц浠誨姟浜屽墠");
},
after:function(){
alert("鎵ц浠誨姟浜屽悗");
},
next:["task3"]
},{
id:"task3",
fn:function(){
alert("鎵ц浠誨姟涓?/span>");
},
before:function(){
alert("鎵ц浠誨姟涓夊墠");
},
after:function(){
alert("鎵ц浠誨姟涓夊悗");
},
//瀹氫箟鍚堝茍鐨勬暟閲?/span>
merge: 3,
next:"EOWF"
},{
id:"task4",
fn:function(){
alert("鎵ц浠誨姟鍥?/span>");
},
before:function(){
alert("鎵ц浠誨姟鍥涘墠");
},
after:function(){
alert("鎵ц浠誨姟鍥涘悗");
},
next:["task3"]
},{
id:"task5",
fn:function(){
alert("鎵ц浠誨姟浜?/span>");
},
before:function(){
alert("鎵ц浠誨姟浜斿墠");
},
after:function(){
alert("鎵ц浠誨姟浜斿悗");
},
next:["task3"]
}]
}
start:{
fn:"begin", //瀵瑰簲澶勭悊鏂規硶鍙互鍦ㄥ唴閮ㄥ畾涔夛紝涔熷彲浠ュ湪澶栭儴瀹氫箟
next:["task1","task2"]
},
end:"end",
tasks:[{
id:"task1",
fn:function(){
alert("鎵ц浠誨姟涓");
},
before:function(){
alert("鎵ц浠誨姟涓鍓?/span>");
},
after:function(){
alert("鎵ц浠誨姟涓鍚?/span>");
},
next:["task4","task5"]
},{
id:"task2",
fn:function(){
alert("鎵ц浠誨姟浜?/span>");
},
before:function(){
alert("鎵ц浠誨姟浜屽墠");
},
after:function(){
alert("鎵ц浠誨姟浜屽悗");
},
next:["task3"]
},{
id:"task3",
fn:function(){
alert("鎵ц浠誨姟涓?/span>");
},
before:function(){
alert("鎵ц浠誨姟涓夊墠");
},
after:function(){
alert("鎵ц浠誨姟涓夊悗");
},
//瀹氫箟鍚堝茍鐨勬暟閲?/span>
merge: 3,
next:"EOWF"
},{
id:"task4",
fn:function(){
alert("鎵ц浠誨姟鍥?/span>");
},
before:function(){
alert("鎵ц浠誨姟鍥涘墠");
},
after:function(){
alert("鎵ц浠誨姟鍥涘悗");
},
next:["task3"]
},{
id:"task5",
fn:function(){
alert("鎵ц浠誨姟浜?/span>");
},
before:function(){
alert("鎵ц浠誨姟浜斿墠");
},
after:function(){
alert("鎵ц浠誨姟浜斿悗");
},
next:["task3"]
}]
}
//////////瀹氫箟寮曟搸////////////
Yi = {};
Yi.Utils = {};
Yi.Utils.execute = function(o){
if(typeof o != 'function')
eval(o)();
else
o();
}
//宸ヤ綔嫻佺被
Yi.Workflow = function(workflowDef){
this.def = workflowDef;
this.tasks = this.def.tasks;
}
//public鎸夌収鐜妭id鏌ユ壘鏌ユ壘
Yi.Workflow.prototype.findTask = function(taskId){
for(var i=0;i<this.tasks.length;i++){
if(this.tasks[i].id == taskId)
return this.tasks[i];
}
}
//public鍚姩宸ヤ綔嫻?/span>
Yi.Workflow.prototype.start = function(){
this.currentTasks = [];
Yi.Utils.execute(this.def.start.fn);
for(var i=0;i<this.def.start.next.length;i++){
this.currentTasks[i] = this.findTask(this.def.start.next[i]);
Yi.Utils.execute(this.currentTasks[i].before);
}
}
//private
Yi.Workflow.prototype.findCurrentTaskById = function(taskId){
for(var i=0;i<this.currentTasks.length;i++){
if(this.currentTasks[i].id == taskId)
return this.currentTasks[i];
}
return null;
}
//private
Yi.Workflow.prototype.removeFromCurrentTasks = function(task){
var temp = [];
for(var i=0;i<this.currentTasks.length;i++){
if(!(this.currentTasks[i] == task))
temp.push(this.currentTasks[i]);
}
this.currentTasks = temp;
temp = null;
}
//public瑙﹀彂褰撳墠鐜妭
Yi.Workflow.prototype.signal = function(taskId){
//鍙鐞嗗綋鍓嶆椿鍔ㄧ幆鑺?/span>
var task = this.findCurrentTaskById(taskId);
if(task == null){
alert("宸ヤ綔嫻佹湭嫻佽漿鍒版鐜妭!");
return;
}
//瀵逛簬鍚堝茍鐨勫鐞?/span>
if(task.merge != undefined){
if(task.merge != 0){
alert("宸ヤ綔嫻佹祦杞潯浠朵笉鍏呭垎!");
return;
}else{
Yi.Utils.execute(task.before);
}
}
//瑙﹀彂褰撳墠鐜妭
Yi.Utils.execute(task.fn);
//瑙﹀彂鍚庡姩浣?/span>
Yi.Utils.execute(task.after);
//涓嬩竴姝ュ鏋滃伐浣滄祦緇撴潫
if(task.next === "EOWF"){
Yi.Utils.execute(this.def.end);
delete this.currentTasks;
return;
}
//閬嶅巻涓嬩竴姝ョ幆鑺?/span>
this.removeFromCurrentTasks(task);
for(var i=0;i<task.next.length;i++){
var tempTask = this.findTask(task.next[i]);
if(!tempTask.inCurrentTasks)
this.currentTasks.push(tempTask);
if(tempTask.merge != undefined){
tempTask.merge--;
tempTask.inCurrentTasks = true;
}
else
Yi.Utils.execute(tempTask.before);
}
}
//public鑾峰彇褰撳墠鐨勬椿鍔ㄧ幆鑺?/span>
Yi.Workflow.prototype.getCurrentTasks = function(){
return this.currentTasks;
}
//public鑾峰彇嫻佺▼瀹氫箟
Yi.Workflow.prototype.getDef = function(){
return this.def;
}
Yi = {};
Yi.Utils = {};
Yi.Utils.execute = function(o){
if(typeof o != 'function')
eval(o)();
else
o();
}
//宸ヤ綔嫻佺被
Yi.Workflow = function(workflowDef){
this.def = workflowDef;
this.tasks = this.def.tasks;
}
//public鎸夌収鐜妭id鏌ユ壘鏌ユ壘
Yi.Workflow.prototype.findTask = function(taskId){
for(var i=0;i<this.tasks.length;i++){
if(this.tasks[i].id == taskId)
return this.tasks[i];
}
}
//public鍚姩宸ヤ綔嫻?/span>
Yi.Workflow.prototype.start = function(){
this.currentTasks = [];
Yi.Utils.execute(this.def.start.fn);
for(var i=0;i<this.def.start.next.length;i++){
this.currentTasks[i] = this.findTask(this.def.start.next[i]);
Yi.Utils.execute(this.currentTasks[i].before);
}
}
//private
Yi.Workflow.prototype.findCurrentTaskById = function(taskId){
for(var i=0;i<this.currentTasks.length;i++){
if(this.currentTasks[i].id == taskId)
return this.currentTasks[i];
}
return null;
}
//private
Yi.Workflow.prototype.removeFromCurrentTasks = function(task){
var temp = [];
for(var i=0;i<this.currentTasks.length;i++){
if(!(this.currentTasks[i] == task))
temp.push(this.currentTasks[i]);
}
this.currentTasks = temp;
temp = null;
}
//public瑙﹀彂褰撳墠鐜妭
Yi.Workflow.prototype.signal = function(taskId){
//鍙鐞嗗綋鍓嶆椿鍔ㄧ幆鑺?/span>
var task = this.findCurrentTaskById(taskId);
if(task == null){
alert("宸ヤ綔嫻佹湭嫻佽漿鍒版鐜妭!");
return;
}
//瀵逛簬鍚堝茍鐨勫鐞?/span>
if(task.merge != undefined){
if(task.merge != 0){
alert("宸ヤ綔嫻佹祦杞潯浠朵笉鍏呭垎!");
return;
}else{
Yi.Utils.execute(task.before);
}
}
//瑙﹀彂褰撳墠鐜妭
Yi.Utils.execute(task.fn);
//瑙﹀彂鍚庡姩浣?/span>
Yi.Utils.execute(task.after);
//涓嬩竴姝ュ鏋滃伐浣滄祦緇撴潫
if(task.next === "EOWF"){
Yi.Utils.execute(this.def.end);
delete this.currentTasks;
return;
}
//閬嶅巻涓嬩竴姝ョ幆鑺?/span>
this.removeFromCurrentTasks(task);
for(var i=0;i<task.next.length;i++){
var tempTask = this.findTask(task.next[i]);
if(!tempTask.inCurrentTasks)
this.currentTasks.push(tempTask);
if(tempTask.merge != undefined){
tempTask.merge--;
tempTask.inCurrentTasks = true;
}
else
Yi.Utils.execute(tempTask.before);
}
}
//public鑾峰彇褰撳墠鐨勬椿鍔ㄧ幆鑺?/span>
Yi.Workflow.prototype.getCurrentTasks = function(){
return this.currentTasks;
}
//public鑾峰彇嫻佺▼瀹氫箟
Yi.Workflow.prototype.getDef = function(){
return this.def;
}
////////搴旂敤緋葷粺///////////////
var wf = new Yi.Workflow(workflowDef);
alert("鍚姩宸ヤ綔嫻?/span>");
wf.start();
alert("灝濊瘯鎵嬪伐鎵ц浠誨姟3,榪斿洖宸ヤ綔嫻佹病鏈夋祦杞埌榪欓噷");
wf.signal("task3");
alert("鍒嗘敮寮濮?/span>");
alert("鎵嬪伐鎵ц浠誨姟1");
wf.signal("task1");
alert("鎵嬪伐鎵ц浠誨姟2");
wf.signal("task2");
alert("鎵嬪伐鎵ц浠誨姟4");
wf.signal("task4");
alert("鎵嬪伐鎵ц浠誨姟5");
wf.signal("task5");
alert("鎵嬪伐鎵ц浠誨姟3");
wf.signal("task3");
function begin(){
alert("嫻佺▼寮濮嬶紝璇ュ嚱鏁板湪澶栭儴瀹氫箟");
}
function end(){
alert("嫻佺▼緇撴潫");
}
var wf = new Yi.Workflow(workflowDef);
alert("鍚姩宸ヤ綔嫻?/span>");
wf.start();
alert("灝濊瘯鎵嬪伐鎵ц浠誨姟3,榪斿洖宸ヤ綔嫻佹病鏈夋祦杞埌榪欓噷");
wf.signal("task3");
alert("鍒嗘敮寮濮?/span>");
alert("鎵嬪伐鎵ц浠誨姟1");
wf.signal("task1");
alert("鎵嬪伐鎵ц浠誨姟2");
wf.signal("task2");
alert("鎵嬪伐鎵ц浠誨姟4");
wf.signal("task4");
alert("鎵嬪伐鎵ц浠誨姟5");
wf.signal("task5");
alert("鎵嬪伐鎵ц浠誨姟3");
wf.signal("task3");
function begin(){
alert("嫻佺▼寮濮嬶紝璇ュ嚱鏁板湪澶栭儴瀹氫箟");
}
function end(){
alert("嫻佺▼緇撴潫");
}
]]>