python多线程教程,python怎样使用多线程

1,python怎样使用多线程连接对象可以是同一个,指针不能是同一个 。假设conn是你的连接对象每个线程使用cur=conn.cursor()来获得指针 。无疑是python,爬虫是python最擅长的方面之一,有许多强大的爬虫库如scrapy 。而node.js虽然也能做爬虫,但在处理多线程方面受到限制,这是硬伤 。
2 , python多线程有几种实现方法基本上有两种,第一种是继承Thread类 , 然后重写run方法,来实现新线程类的创建 。第二种是写一个类实现Runnable()接口 , 然后将这个类传给一个Thread对象来创建线程对象 。这两种方法本质是一样的 。因为Thread类也实现了Runnable接口 。python 的gil规定每个时刻只能有一个线程访问python虚拟机,所以你要用python的多线程来做计算是很不合算的,但是对于io密集型的应用,例如网络交互来说,python的多线程还是非常给力的 。如果你是一个计算密集型的任务,非要用python来并行执行.
3,Python并发编程之创建多线程的几种方法Django: Py Web应用开发框架Diesel:基于Greenlet的事件I/O框架Flask:一个用Py编写的轻量级Web应用框架Cubes:轻量级Py OLAP框架Kartograph.py:创造矢量地图的轻量级Py框架Pulsar:Py的事件驱动并发框架Web2py:全栈式Web框架Falcon:构建云API和网络应用后端的高性能Py框架Dpark:Py版的SparkBuildbot:基于Py的持续集成测试框架Zerorpc:基于ZeroMQ的高性能分布式RPC框架Bottle: 微型Py Web框架Tornado:异步非阻塞IO的Py Web框架webpy: 轻量级的Py Web框架Scrapy:Py的爬虫框架谁说python多线程支持不好 , 比起ruby,比起perl,好的不要太多 。python有很多实现多线程的方法:1.挂锁2.queue 队列3.信号机也可以自己构建循环缓冲区我自己总结的构建线程的一些思路:抽象出共享空间,就是读线程和写线程均要访问的那块区域--临界区域,在这个对象里面设置读方法和写方法 , 并挂锁,也就说不能有2个或者2个以上的线程同时操作共享区域,挂锁 的时候注意死锁问题 。这就是基本的线程同步了 , 如果要加上缓冲就要考虑记录每个线程操作到什么位置,就是位置信息 。代码不贴了,看我blog里面有几个写python的http://hi.baidu.com/linuxbird只要记得几个思路就可以了【python多线程教程,python怎样使用多线程】
4,python多线程几种方法实现Python进阶(二十六)-多线程实现同步的四种方式临界资源即那些一次只能被一个线程访问的资源,典型例子就是打印机 , 它一次只能被一个程序用来执行打印功能,因为不能多个线程同时操作 , 而访问这部分资源的代码通常称之为临界区 。锁机制threading的Lock类,用该类的acquire函数进行加锁 , 用realease函数进行解锁import threadingimport timeclass Num:def __init__(self):self.num = 0self.lock = threading.Lock()def add(self):self.lock.acquire()#加锁,锁住相应的资源self.num += 1num = self.numself.lock.release()#解锁,离开该资源return numn = Num()class jdThread(threading.Thread):def __init__(self,item):threading.Thread.__init__(self)self.item = itemdef run(self):time.sleep(2)value = http://www.lisdn.com/gkrj/shwd/n.add()#将num加1,并输出原来的数据和+1之后的数据print(self.item,value)for item in range(5):t = jdThread(item)t.start()t.join()#使线程一个一个执行12345678910111213141516171819202122232425262728当一个线程调用锁的acquire()方法获得锁时,锁就进入“locked”状态 。每次只有一个线程可以获得锁 。如果此时另一个线程试图获得这个锁,该线程就会变为“blocked”状态,称为“同步阻塞”(参见多线程的基本概念) 。直到拥有锁的线程调用锁的release()方法释放锁之后 , 锁进入“unlocked”状态 。线程调度程序从处于同步阻塞状态的线程中选择一个来获得锁,并使得该线程进入运行(running)状态 。信号量信号量也提供acquire方法和release方法 , 每当调用acquire方法的时候,如果内部计数器大于0,则将其减1,如果内部计数器等于0,则会阻塞该线程 , 知道有线程调用了release方法将内部计数器更新到大于1位置 。import threadingimport timeclass Num:def __init__(self):self.num = 0self.sem = threading.Semaphore(value = 3)#允许最多三个线程同时访问资源def add(self):self.sem.acquire()#内部计数器减1self.num += 1num = self.numself.sem.release()#内部计数器加1return numn = Num()class jdThread(threading.Thread):def __init__(self,item):threading.Thread.__init__(self)self.item = itemdef run(self):time.sleep(2)value = n.add()print(self.item,value)for item in range(100):python 的gil规定每个时刻只能有一个线程访问python虚拟机,所以你要用python的多线程来做计算是很不合算的,但是对于io密集型的应用 , 例如网络交互来说,python的多线程还是非常给力的 。如果你是一个计算密集型的任务,非要用python来并行执行.

    推荐阅读