亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

一段java并發同步示例代碼的疑惑

一段java并發同步示例代碼的疑惑

MMTTMM 2019-04-21 20:37:00
importjava.util.ArrayList;importjava.util.concurrent.Callable;importjava.util.concurrent.ExecutionException;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.Future;publicclassCachedThreadPool{privatestaticintid=0;publicstaticvoidmain(String[]args){newCachedThreadPool().fun();}privatevoidfun(){ExecutorServiceexe=Executors.newCachedThreadPool();ArrayListlist=newArrayList();for(inti=0;i
查看完整描述

2 回答

?
慕標琳琳

TA貢獻1830條經驗 獲得超9個贊

因為放到TaskCall里之后,synchronized表示在一個TaskCall實例上同步執行。有3個實例,它們之間是不同步的。
而放在外面是在一個CachedThreadPool中同步。
                            
查看完整回答
反對 回復 2019-04-21
?
拉莫斯之舞

TA貢獻1820條經驗 獲得超10個贊

按你的測試代碼,樓上回答能解釋。
然而:
測試代碼有錯誤,以下是正確的測試代碼:
importjava.util.ArrayList;
importjava.util.Collections;
importjava.util.List;
importjava.util.concurrent.*;
publicclassCachedThreadPool{
privatestaticintid=0;
privatestaticListresults=Collections.synchronizedList(newArrayList<>());
publicstaticvoidmain(String[]args)throwsException{
newCachedThreadPool().fun();
}
privatevoidfun()throwsException{
ExecutorServiceexe=Executors.newCachedThreadPool();
List>list=newArrayList<>();
for(inti=0;i<100;i++){
list.add(exe.submit(newTaskCall()));
}
exe.shutdown();
for(Futurefs:list){
fs.get();
}
//斷言
for(inti=1;iif(results.get(i)!=results.get(i-1)+1){
thrownewIllegalStateException();
}
}
System.out.println("\n"+results);
}
privatesynchronizedStringgetId(){
++id;
System.out.print(id+",");
results.add(id);
returnid+"";
}
classTaskCallimplementsCallable{
@Override
publicStringcall()throwsException{
returngetId();
}
}
}
然后是分析:
先翻譯幾處代碼,以便理解:
1.
privatesynchronizedStringgetId(){
return++id+"";
}
等價于
privateStringgetId(){
synchronized(this){
return++id+"";
}
}
2.
//TaskCall
returngetId();
等價于
//TaskCall
returnCachedThreadPool.this.getId();
可以看到同步范圍僅限于this,也就是CachedThreadPool的實例,只有一個。但是static字段是類的字段,不是實例的字段,因此不在加鎖范圍!然而,同步會刷新代碼塊內所有用到的變量,不論static與否。而唯一實例使++代碼塊被單線程獨占。兩者結合,意外地做到了并發安全。
還可以試驗一下,synchronized改成synchronized(CachedThreadPool.class){...},并把main標為synchronized,會導致死鎖。
synchronized的知識:指定了一個同步范圍,進出范圍時會刷新相關變量,阻止其他線程進入該范圍。synchronizedmethod的范圍是this,synchronizedstaticmethod的范圍是class。
補充:如果同一個類有的方法寫了synchronized,有的方法沒寫,也達不到同步。
                            
查看完整回答
反對 回復 2019-04-21
  • 2 回答
  • 0 關注
  • 379 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號