Python论坛的帖子：

Sun Oct 2 09:03:54 HKT 2005

我运行了一下~~没有问题啊~
我想你所谓的"死了",应该是因为你的程序中全部都只是对类和函数进行了定义~可是你并没有调用它吧~~~
                    
 
个人愚见~有什么不对的地方~请各位大虾批评指正~谢谢~
iAdo~
----- Original Message ----- 
From: 科峰 
To: python-chinese at lists.python.cn 
Sent: Sunday, October 02, 2005 1:14 AM
Subject: [python-chinese] 关于线程threading


我在看python编程金典，其中有段代码，我照书上敲入后，却运行总是死在那里，不知道什么原因，我贴出代码，是实现了一个有同步功能的整数变量：
import threading

class SynchronizedInteger:
    """Class that provides synchronized access to an integer"""

    def __init__( self ):
        """Initialize integer, buffers count and condition variable"""

        self.buffer = -1
        self.occupiedBufferCount = 0 # number of occupied buffers
        self.threadCondition = threading.Condition()

    def set( self, newNumber ):
        """Set value of integer--blocks until lock acquired"""

        #block until lock released then acquire lock
        self.threadCondition.acquire()
        while self.occupiedBufferCount == 1:
            print "%s 试图写." % \
                  threading.currentThread ().getName()
            self.displayState( "缓冲满." + \
                               threading.currentThread().getName() + "等待." )
            
            self.threadCondition.wait()

        self.buffer = newNumber
        self.occupiedBufferCount = 1

        self.displayState( "%s 写下了 %d" % \
                           ( threading.currentThread().getName(), newNumber ) )

        self.threadCondition.notify()        
        self.threadCondition.release()
        
        
    def get( self ):
        """Get value of integer--blocks until lock acquired""" 

        self.threadCondition.acquire()
        while self.occupiedBufferCount == 0:
            print "%s 试图读." % \
                  threading.currentThread().getName()
            self.displayState ( "缓冲空." + \
                               threading.currentThread().getName() + "等待." )
            
            
            self.threadCondition.wait()

        
        tempNumber = self.buffer
        self.occupiedBufferCount = 0

        self.displayState( "%s 读取了 %d" % \
                           ( threading.currentThread().getName(), tempNumber ) )
        
        self.threadCondition.notify()
        self.threadCondition.release ()
        return tempNumber

    def displayState( self, operation ):
        """Display current state"""

        print "%-35s %-9s%2s\n" % \
              ( operation, self.buffer, self.occupiedBufferCount )

 
请问上面代码有什么问题吗


-- 
努力努力
 

--------------------------------------------------------------------------------


_______________________________________________
python-chinese list
python-chinese at lists.python.cn
http://python.cn/mailman/listinfo/python-chinese

标题：[python-chinese] (no subject)