Pythonのスレッド - 彼らはここpostgreSQLの

Question

にアクセスしたときにクラッシュすると、正常に動作し、簡単なスレッドプログラムです：

import psycopg2 
import threading 
import time 

class testit(threading.Thread): 
    def __init__(self, currency): 
     threading.Thread.__init__(self) 
     self.currency = currency 

    def run(self): 
     global SQLConnection 
     global cursor 
     SQLString = "Select dval from ddata where dname ='%s' and ddate = '2009-07-17'" \ 
       %self.currency 
     z = time.time() 
     while (time.time() - z) < 2: 
      print SQLString 

SQLConnection = psycopg2.connect(database = "db", user = "xxxx", password = "xxxx") 
cursor = SQLConnection.cursor() 

a = testit('EURCZK') 
b = testit('EURPLN') 
a.start() 
b.start() 

しかし、すぐに私は次のコードでスレッドでのPostgreSQLデータベースにアクセスして起動しようとして、私はいつも

import psycopg2 
import threading 
import time 

class testit(threading.Thread): 
    def __init__(self, currency): 
     threading.Thread.__init__(self) 
     self.currency = currency 

    def run(self): 
     global SQLConnection 
     global cursor 
     SQLString = "Select dval from ddata where dname ='%s'and ddate = '2009-07-17'" %self.currency 
     z = time.time() 
     while (time.time() - z) < 2: 
      cursor.execute(SQLString) 
      print cursor.fetchall() 

SQLConnection = psycopg2.connect(database = "db", user = "xxxx", password = "xxxx") 
cursor = SQLConnection.cursor() 

a = testit('EURCZK') 
b = testit('EURPLN') 
a.start() 
b.start() 

唯一の違いはwhileループです。私はスレッドプログラミングにかなり新しいです。 postgresライブラリ（psycopg2）は "スレッドセーフ"ではありませんか？これはすべてWindows XP上で実行されています。私は何でもできる？

ありがとうございました。

Answer 1

global SQLConnection 
global cursor 

複数のスレッドからグローバルにアクセスしているようですか？ 決してする必要があります。それらのグローバルがスレッドセーフでない場合、または適切なロックを自分で提供している場合を除きます。

これで、2つのスレッドが同じ接続と同じカーソルにアクセスするようになりました。彼らはお互いのつま先に足を踏み入れます。 psycopg2接続はスレッドセーフであるかもしれませんが、カーソルはありません。

スレッドごとに1つのカーソル（恐らく1つの接続も同様）を使用します。

Answer 2

ビンゴが働いています。誰かが答えを残したが、それを取り除いたように見え、各スレッドに独自の接続を与える。そしてそれはそれを解決するうん。したがって、このコードの動作：

import psycopg2 
import threading 
import time 

class testit(threading.Thread): 
    def __init__(self, currency): 
     threading.Thread.__init__(self) 
     self.currency = currency 
     self.SQLConnection = psycopg2.connect(database = "db", user = "xxxx", password = "xxxx") 
     self.cursor = self.SQLConnection.cursor() 

    def run(self): 
     SQLString = "Select dval from ddata where dname ='%s' and ddate = '2009-07-17'" \ 
       %self.currency 
     z = time.time() 
     while (time.time() - z) < 2: 
      self.cursor.execute(SQLString) 
      print self.cursor.fetchall() 

a = testit('EURCZK') 
b = testit('EURPLN') 
a.start() 
b.start()