Python-сообщество

class ConnectionThread(threading.Thread):
    def run(self):
        # Connect to the server:
        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client.connect (('localhost', 2727))

        # Retrieve and unpickle the list object:
        print pickle.loads(client.recv(1024))

        # Send some messages:
        for x in xrange(10):
            client.send('Hey. ' + str(x) + '\n')

        # Close the connection
        client.close()

import socket
import threading
import time
import random

class client(threading.Thread):
	print "Run"
	temp = 0 + random.randint(1,100)
	def connect(self):
		HOST = "127.0.0.1"
		PORT = 411
		s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
		s.connect((HOST, PORT))
		print "connect true"
		print "temp = ",self.temp
		return

	def run(self):
		self.connect()
		return

print "thread 1"
client().start()
time.sleep(2)
print "thread 2"
client().start()

Run
thread 1
connect true
temp =  43
thread 2
connect true
temp =  43

#!/usr/bin/env python
# -*-coding: utf-8 -*-
# vim: sw=4 ts=4 expandtab ai

import subprocess
import threading
import Queue

def ipgen(oct1,oct2,oct3,oct4):
    for o1 in xrange(oct1[0],oct1[1]+1):
        for o2 in xrange(oct2[0],oct2[1]+1):
            for o3 in xrange(oct3[0],oct3[1]+1):
                for o4 in xrange(oct4[0],oct4[1]+1):
                    yield '%s.%s.%s.%s' % (o1,o2,o3,o4)

def ping2mac(ip):
    subprocess.call(("/bin/ping -c1 -s1 %s &>/dev/null" % ip), \
            shell=True)
    macstr = subprocess.Popen(('arp -an | grep "(%s)"' % ip), \
             shell=True, stdout=subprocess.PIPE)
    mac = macstr.communicate()[0]
    if mac:
        mac = mac.split()[3]
        if mac != '<incomplete>':
            return mac
    return ''

def pinger(que):
    while True:
        ip = que.get()
        mac = ping2mac(ip)
        if mac: print ip,mac
        que.task_done()

if __name__ == '__main__':
    queue = Queue.Queue()
    for i in xrange(20):
        worker = threading.Thread(target=pinger,args=(queue,))
        worker.setDaemon(True)
        worker.start()

    for ip in ipgen((192,192),(168,168),(0,0),(0,255)):
        queue.put(ip)
    queue.join()

#!/usr/bin/env python
# -*-coding: utf-8 -*-
# vim: sw=4 ts=4 expandtab ai
# pylint: disable-msg=C0301

import socket
import threading
import time

class client(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        print "RUN!"
        self.HOST = "192.168.0.1"
        self.PORT = 80
        self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    def connect(self):
        self.s.connect((self.HOST, self.PORT))
        print "connect true"
        return

    def run(self):
        self.connect()
        return
print "thread 1"
c1 = client()
c1.start()
time.sleep(3)
print "thread 2"
c2 = client()
c2.start()

alex@debian-gate:~$ python ./test/thread.py
thread 1
RUN!
connect true
thread 2
RUN!
connect true

class client(threading.Thread):
	def __init__(self,name):
		threading.Thread.__init__(self, name=name)
		self.HOST = "127.0.0.1"
		self.PORT = 411
		self.s = socket.socket(socket.AF_INET, 
	def connect(self):
		self.s.connect((self.HOST, self.PORT))
		return
	def sendmessage(self, text):
		self.s.send(text)
		return