线程锁加异常捕获的问题

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)

上边是一个线程类中了读取网页的类方法

我想添加一个循环,如果遇到指定的错误等待数秒后重新从循环执行一次

直到读取成功跳出循环再解除线程锁

循环应该放在哪一行
finally该放在哪一行

luffy.deng

这样搞发生异常时跟单线程有什么区别？

9ibook

每个线程处理各自的任务,同时只能有一个线程能读取网页
但是可能会出现一些意外,像网络断开
如果出现这种意外情况就锁住所有线程,当前读取网页的线程进入等待直到网络恢复正常才释放锁

2gua

那你用多进程，而不是线程，这样实现线程的方式，肯定会出问题的。

luffy.deng

每个线程处理各自的任务,同时只能有一个线程能读取网页
但是可能会出现一些意外,像网络断开
如果出现这种 ...
9ibook 发表于 2010-05-30 00:33

我还是看不出来有什么理由  获得锁以后sleep(15)  。 如果你确实就是想设计成这样，那循环就很简单了。

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()
    

复制代码