OSError：[Errno 11]リソースを一時的に使用できません。この原因は何ですか？

Question

背景

私は、相互に通信する必要がある2つのpythonのプロセスを持っています。細分化は、Pipeという名前のクラスによって処理されます。通信する必要のある情報の大部分が辞書の形になっているので、私はこれに対して別のクラスを作ったので、Pipeはこれを行うためのかなり簡単なプロトコルを実装しています。ここで

はパイプコンストラクタです：

def __init__(self,sPath): 
    """ 
    create the fifo. if it already exists just associate with it 
    """ 
    self.sPath = sPath 
    if not os.path.exists(sPath): 
     try: 
      os.mkfifo(sPath) 
     except: 
      raise Exception('cannot mkfifo at path \n {0}'.format(sPath)) 
    self.iFH = os.open(sPath,os.O_RDWR | os.O_NONBLOCK) 
    self.iFHBlocking = os.open(sPath,os.O_RDWR) 

だから、理想的に、私はちょうど同じパスで各プロセスにパイプを構築するだろうし、彼らは素敵な話をすることができるだろう。

ここではほとんど必要ではないと思うので、私はプロトコルについての説明を省略します。

：

def base_read_blocking(self,iLen): 
    self.lock() 
    lBytes = os.read(self.iFHBlocking,iLen) 
    self.unlock() 
    return lBytes 

def base_read(self,iLen): 
    print('entering base read') 
    self.lock() 
    lBytes = os.read(self.iFH,iLen) 
    self.unlock() 
    print('exiting base read') 
    return lBytes 

def base_write_blocking(self,lBytes): 
    self.lock() 
    safe_write(self.iFHBlocking,lBytes) 
    self.unlock() 

def base_write(self,lBytes): 
    print('entering base write') 
    self.lock() 
    safe_write(self.iFH,lBytes) 
    self.unlock() 
    print('exiting base write') 

safe_writeが

def safe_write(*args, **kwargs): 
    while True: 
     try: 
      return os.write(*args, **kwargs) 
     except OSError as e: 
      if e.errno == 35: 
       import time 
       print(".") 
       time.sleep(0.5) 
      else: 
       raise 

は、ロックとロック解除は、このように処理され、別の記事で示唆された。

すべての読み取りおよび書き込み操作は、以下の「ベース」の機能を利用します

def lock(self): 
    print('locking...') 
    while True: 
     try: 
      os.mkdir(self.get_lock_dir()) 
      print('...locked') 
      return 
     except OSError as e: 
      if e.errno != 17: 
       raise e 

def unlock(self): 
    try: 
     os.rmdir(self.get_lock_dir()) 
    except OSError as e: 
     if e.errno != 2: 
      raise e 
    print('unlocked') 

問題

この時々が起こります

....in base_read 
lBytes = os.read(self.iFH,iLen) 
OSError: [Errno 11] Resource temporarily unavailable 

は、時にはそれは大丈夫です。

マジカルソリューション

私が起こってからこの問題を停止しているように見えます。これは私自身の質問に私が答えるものではないことに注意してください。私の質問は次のセクションで説明します。

私はもっとこのように見えるように読み取り機能を変更し、それがものを整理：質問

を

def base_read(self,iLen): 
    while not self.ready_for_reading(): 
     import time 
     print('.') 
     time.sleep(0.5) 

    lBytes = ''.encode('utf-8') 
    while len(lBytes)<iLen: 
     self.lock() 
     try: 
      lBytes += os.read(self.iFH,iLen) 
     except OSError as e: 
      if e.errno == 11: 
       import time 
       print('.') 
       time.sleep(0.5) 
     finally: 
      self.unlock() 
     return lBytes 


def ready_for_reading(self): 
    lR,lW,lX = select.select([self.iFH,],[],[],self.iTimeout) 
    if not lR: 
     return False 
    lR,lW,lX = select.select([self.iFHBlocking],[],[],self.iTimeout) 
    if not lR: 
     return False 
    return True 

私はそれが一時的に利用できない正確な理由を見つけるのに苦労しています。 2つのプロセスは、ロック機構のために実際の名前付きパイプに同時にアクセスすることはできません（私が間違っていない限り）？これは私のプログラムが考慮していないFIFOにとってより基本的なものなのですか？

私が本当に欲しいのは、説明です...私が見つけた解決策は、魔法のように見えます。誰でも説明を提供できますか？

システム

• のUbuntu 12.04、
• Python3.2。3

Answer 1

私は以前にsimilar problem with Javaを持っていました。受け入れられた答えを見てみましょう---問題はループ内に新しいスレッドを作成していたことでした。パイプを作成するコードを見て、複数のパイプを作成していないことを確認することをお勧めします。