線程鎖加異常捕獲的問題

9ibook

def openurl(self,url,data=None):
        if data:self.curl.setopt(pycurl.POSTFIELDS,data)
        self.curl.setopt(pycurl.URL,url)
        self.rep.seek(0)
        self.rep.truncate()
        mylock.acquire()
        try:
            self.curl.perform()
        except Exception,error:
            if self.errorCode.has_key(error[0]):
                print ">",self.errorCode[error[0]]
                if error[0]==7:   #1
                    time.sleep(15)
            else:
                print ">",error
        finally:
            mylock.release()
        s=self.rep.getvalue()
        return str(s)

上邊是一個線程類中了讀取網(wǎng)頁的類方法

我想添加一個循環(huán),如果遇到指定的錯誤等待數(shù)秒后重新從循環(huán)執(zhí)行一次

直到讀取成功跳出循環(huán)再解除線程鎖

循環(huán)應該放在哪一行
finally該放在哪一行

luffy.deng

這樣搞發(fā)生異常時跟單線程有什么區(qū)別？

9ibook

每個線程處理各自的任務(wù),同時只能有一個線程能讀取網(wǎng)頁
但是可能會出現(xiàn)一些意外,像網(wǎng)絡(luò)斷開
如果出現(xiàn)這種意外情況就鎖住所有線程,當前讀取網(wǎng)頁的線程進入等待直到網(wǎng)絡(luò)恢復正常才釋放鎖

2gua

那你用多進程，而不是線程，這樣實現(xiàn)線程的方式，肯定會出問題的。

luffy.deng

每個線程處理各自的任務(wù),同時只能有一個線程能讀取網(wǎng)頁
但是可能會出現(xiàn)一些意外,像網(wǎng)絡(luò)斷開
如果出現(xiàn)這種 ...
9ibook 發(fā)表于 2010-05-30 00:33

我還是看不出來有什么理由  獲得鎖以后sleep(15)  。 如果你確實就是想設(shè)計成這樣，那循環(huán)就很簡單了。

1.     n=2
   
2.     mylock.acquire()  
   
3.     while n:   
   
4.         try:
   
5.             self.curl.perform()
   
6.             break
   
7.         except Exception,e:
   
8.             n-=1
   
9.             time.sleep(5)            
   
10.     mylock.release()
    

復制代碼