Java并發編程基礎知識片段
Java 5并發包的加入,給Java的并發程序的開發帶來了很多的好處,在此列舉一些并發編程中應該掌握的一些基礎知識片斷,這些片斷基本都是由一些問題組成,在片段中沒有直接寫出答案,由于可用來解決這些片段的方法還是很多的,因此只是提到了解決問題可選方案的關鍵字,如果有需要進一步了解的話,基本上google一下應該就能查出來了,不過就像之前有朋友說的,如果不是經常用的話,其實就算現在知道了也是會忘記的,這很正常,:),不過我更認為那是因為知其然而不知其所以然造成的,很多東西如果知道原理的話,基本上還是可以記得很長一段時間的。
片斷一
在main中啟動兩個線程,例如:
Thread a=new Thread(){
public void run(){
System.out.println("Call A");
try{
Thread.sleep(1000);
}
catch(Exception e){
e.printStackTrace();
}
}
};
Thread b=new Thread(){
public void run(){
try{
Thread.sleep(500);
}
catch(Exception e){
e.printStackTrace();
}
System.out.println("Call B");
}
};
a.start();
b.start();
System.out.println("execute here");
在這樣的方式下,執行時會出現什么樣的效果;
怎么樣才能保證字符串的打印順序是:"Call B"-->"Call A"-->"execute here"呢?(提示:join、wait/notify、Semphore、Lock等)
在做到了上面打印順序控制后,怎么樣才能做到如果線程b執行了100毫秒還沒執行完的話則直接繼續線程a的執行呢?(提示:ExecutorServices、Future)
片段二
也是個控制順序的問題,假設有如下一段代碼:
for(int i=0;i<10;i++){
Thread thread=new Thread(){
public void run(){
...
}
};
thread.setName("Thread-"+i);
thread.start();
}
System.out.println("All Executed");
需要做到所有線程同時運行,而不是按照for的順序一個一個啟動,并且要求All Executed需要在所有線程都執行完畢后才打印,有什么辦法做到呢?(提示:CountDownLatch等)
片段三
Map<String,Object> datas=new ConcurrentHashMap<String,Object>();
public Object get(String keyName){
Object data=null;
if(!datas.containsKey(keyName)){
data=createData(keyName);
datas.put(keyName,data);
}
else{
data=datas.get(keyName;)
}
return data;
}
上面這段代碼在并發時會出什么問題呢,為什么?
如果有問題的話,應該怎么去解決呢?(提示:Synchronized、Lock、FutureTask等)
片段四
ThreadPoolExecutor executor=new ThreadPoolExecutor(10,100,60L,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(20),new ThreadPoolExecutor.AbortPolicy());
一個這樣的線程池,當并發請求數為15時會是怎么個狀況?(池的使用狀況,例如活動線程數、隊列中的數等)
當并發請求數為100的時候是什么狀況?
當并發請求數為200的時候是什么狀況?
當30秒內不再有請求時會怎么樣?
當2分鐘內沒有請求時會怎么樣?
如果換成以下方式初始化池又會怎么樣呢:
ThreadPoolExecutor executor=new ThreadPoolExecutor(10,150,20L,TimeUnit.SECONDS,new SynchronousQueue<Runnable>(),new ThreadPoolExecutor.AbortPolicy());
片段五
怎么查看jvm中線程的執行狀況,線程的狀態有哪幾種,分別表示什么含義?
ThreadFactory有什么用?
如果要捕捉線程中拋出的異常,可以怎么做呢?
如果TimerTask拋出運行時異常會不會影響到同一個Timer中其他的TimerTask的執行呢,SchedularThreadPoolExecutor和Timer有什么不同?
片段六
常見的一個例子:
private int count;
public synchronized int getNext(){
return count++;
}
在JDK5有什么別的方法來進行實現嗎?
像JDK5中的AtomicInteger的incrementAndGet是怎么實現的呢?
如果這個count要按線程來獨立管理,即每個線程有自己的一個count,要怎么做呢?
片斷一
在main中啟動兩個線程,例如:
Thread a=new Thread(){
public void run(){
System.out.println("Call A");
try{
Thread.sleep(1000);
}
catch(Exception e){
e.printStackTrace();
}
}
};
Thread b=new Thread(){
public void run(){
try{
Thread.sleep(500);
}
catch(Exception e){
e.printStackTrace();
}
System.out.println("Call B");
}
};
a.start();
b.start();
System.out.println("execute here");
在這樣的方式下,執行時會出現什么樣的效果;
怎么樣才能保證字符串的打印順序是:"Call B"-->"Call A"-->"execute here"呢?(提示:join、wait/notify、Semphore、Lock等)
在做到了上面打印順序控制后,怎么樣才能做到如果線程b執行了100毫秒還沒執行完的話則直接繼續線程a的執行呢?(提示:ExecutorServices、Future)
片段二
也是個控制順序的問題,假設有如下一段代碼:
for(int i=0;i<10;i++){
Thread thread=new Thread(){
public void run(){
...
}
};
thread.setName("Thread-"+i);
thread.start();
}
System.out.println("All Executed");
需要做到所有線程同時運行,而不是按照for的順序一個一個啟動,并且要求All Executed需要在所有線程都執行完畢后才打印,有什么辦法做到呢?(提示:CountDownLatch等)
片段三
Map<String,Object> datas=new ConcurrentHashMap<String,Object>();
public Object get(String keyName){
Object data=null;
if(!datas.containsKey(keyName)){
data=createData(keyName);
datas.put(keyName,data);
}
else{
data=datas.get(keyName;)
}
return data;
}
上面這段代碼在并發時會出什么問題呢,為什么?
如果有問題的話,應該怎么去解決呢?(提示:Synchronized、Lock、FutureTask等)
片段四
ThreadPoolExecutor executor=new ThreadPoolExecutor(10,100,60L,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(20),new ThreadPoolExecutor.AbortPolicy());
一個這樣的線程池,當并發請求數為15時會是怎么個狀況?(池的使用狀況,例如活動線程數、隊列中的數等)
當并發請求數為100的時候是什么狀況?
當并發請求數為200的時候是什么狀況?
當30秒內不再有請求時會怎么樣?
當2分鐘內沒有請求時會怎么樣?
如果換成以下方式初始化池又會怎么樣呢:
ThreadPoolExecutor executor=new ThreadPoolExecutor(10,150,20L,TimeUnit.SECONDS,new SynchronousQueue<Runnable>(),new ThreadPoolExecutor.AbortPolicy());
片段五
怎么查看jvm中線程的執行狀況,線程的狀態有哪幾種,分別表示什么含義?
ThreadFactory有什么用?
如果要捕捉線程中拋出的異常,可以怎么做呢?
如果TimerTask拋出運行時異常會不會影響到同一個Timer中其他的TimerTask的執行呢,SchedularThreadPoolExecutor和Timer有什么不同?
片段六
常見的一個例子:
private int count;
public synchronized int getNext(){
return count++;
}
在JDK5有什么別的方法來進行實現嗎?
像JDK5中的AtomicInteger的incrementAndGet是怎么實現的呢?
如果這個count要按線程來獨立管理,即每個線程有自己的一個count,要怎么做呢?
posted on 2008-06-20 01:29 BlueDavy 閱讀(7930) 評論(4) 編輯 收藏 所屬分類: Java