java讀數據超時（java超時等待）

本文目錄一覽：

• 1、雲南北大青鳥java培訓告訴你在Java程序中處理資料庫超時與死鎖？
• 2、北大青鳥java培訓：在Java程序中處理資料庫超時與死鎖？
• 3、java 方法 執行超時處理

雲南北大青鳥java培訓告訴你在Java程序中處理資料庫超時與死鎖？

每個使用關係型資料庫的程序都可能遇到數據死鎖或不可用的情況，而這些情況需要在代碼中編程來解決;本文主要介紹與資料庫事務死鎖等情況相關的重試邏輯概念，此外，還會探討如何避免死鎖等問題，文章以DB2(版本9)與為例進行講解。

什麼是資料庫鎖定與死鎖

鎖定(Locking)發生在當一個事務獲得對某一資源的「鎖」時，這時，其他的事務就不能更改這個資源了，這種機制的存在是為了保證數據一致性;在設計與資料庫交互的程序時，必須處理鎖與資源不可用的情況。鎖定是個比較複雜的概念，仔細說起來可能又需要一大篇，所以在本文中，只把鎖定看作是一個臨時事件，這意味著如果一個資源被鎖定，它總會在以後某個時間被釋放。而死鎖發生在當多個進程訪問同一資料庫時，其中每個進程擁有的鎖都是其他進程所需的，由此造成每個進程都無法繼續下去。

如何避免鎖

我們可利用事務型資料庫中的隔離級別機制來避免鎖的創建，正確地使用隔離級別可使程序處理更多的並發事件(如允許多個用戶訪問數據)，還能預防像丟失修改(LostUpdate)、讀「臟」數據(DirtyRead)、不可重複讀(NonrepeatableRead)及「虛」(Phantom)等問題。

隔離級別問題現象

丟失修改讀「臟」數據不可重複讀「虛」

可重複讀取NoNoNoNo

讀取穩定性NoNoNoYes

游標穩定性NoNoYesYes

未提交的讀NoYesYesYes

表1：DB2的隔離級別與其對應的問題現象

在只讀模式中，就可以防止鎖定發生，而不用那些未提交只讀隔離級別的含糊語句。麗江電腦培訓發現一條SQL語句當使用了下列命令之一時，就應該考慮只讀模式了

北大青鳥java培訓：在Java程序中處理資料庫超時與死鎖？

每個使用關係型資料庫的程序都可能遇到數據死鎖或不可用的情況，而這些情況需要在代碼中編程來解決;本文主要介紹與資料庫事務死鎖等情況相關的重試邏輯概念，此外，還會探討如何避免死鎖等問題，文章以DB2(版本9)與為例進行講解。

什麼是資料庫鎖定與死鎖鎖定(Locking)發生在當一個事務獲得對某一資源的「鎖」時，這時，其他的事務就不能更改這個資源了，這種機制的存在是為了保證數據一致性;在設計與資料庫交互的程序時，必須處理鎖與資源不可用的情況。

鎖定是個比較複雜的概念，仔細說起來可能又需要一大篇，所以在本文中，只把鎖定看作是一個臨時事件，這意味著如果一個資源被鎖定，它總會在以後某個時間被釋放。

而死鎖發生在當多個進程訪問同一資料庫時，其中每個進程擁有的鎖都是其他進程所需的，由此造成每個進程都無法繼續下去。

如何避免鎖我們可利用事務型資料庫中的隔離級別機制來避免鎖的創建，正確地使用隔離級別可使程序處理更多的並發事件(如允許多個用戶訪問數據)，還能預防像丟失修改(LostUpdate)、讀「臟」數據(DirtyRead)、不可重複讀(NonrepeatableRead)及「虛」(Phantom)等問題。

隔離級別問題現象丟失修改讀「臟」數據不可重複讀「虛」可重複讀取NoNoNoNo讀取穩定性NoNoNoYes游標穩定性NoNoYesYes未提交的讀NoYesYesYes表1：DB2的隔離級別與其對應的問題現象在只讀模式中，就可以防止鎖定發生，而不用那些未提交只讀隔離級別的含糊語句。

浙江電腦培訓發現一條SQL語句當使用了下列命令之一時，就應該考慮只讀模式了

java 方法 執行超時處理

java 1.5以上的Future類可以執行超時處理。

jdk1.5自帶的並發庫中Future類中重要方法包括get()和cancel()，get()獲取數據對象，如果數據沒有載入，就會阻塞直到取到數據，而 cancel()是取消數據載入。另外一個get(timeout)操作，表示如果在timeout時間內沒有取到就失敗返回，而不再阻塞。

代碼如下：

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import com.sun.corba.se.impl.orbutil.closure.Future;

import com.sun.corba.se.impl.orbutil.threadpool.TimeoutException;

public class ThreadTest {  

    public static void main(String[] args) throws InterruptedException,  

            ExecutionException {  

        final ExecutorService exec = Executors.newFixedThreadPool(1);  

        CallableString call = new CallableString() {  

            public String call() throws Exception {  

                //開始執行耗時操作  

                Thread.sleep(1000 * 5);  

                return “線程執行完成.”;  

            }  

        };  

        try {  

            FutureString future = exec.submit(call);  

            String obj = future.get(1000 * 1, TimeUnit.MILLISECONDS); //任務處理超時時間設為 1 秒  

            System.out.println(“任務成功返回:” + obj);  

        } catch (TimeoutException ex) {  

            System.out.println(“處理超時啦….”);  

            ex.printStackTrace();  

        } catch (Exception e) {  

            System.out.println(“處理失敗.”);  

            e.printStackTrace();  

        }  

        // 關閉線程池  

        exec.shutdown();  

    }  

}