FilesExpand file tree

 master

/

NetAcceptThread.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

62 lines (52 loc) · 2.04 KB

 master

/

NetAcceptThread.py

Copy path

Top

File metadata and controls

• Code
• Blame

62 lines (52 loc) · 2.04 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

# -*- coding: UTF-8 -*-

import threading, socket, select

import NetThread

from GlobalData import MagicNum, ConfigData

_metaclass_ = type

class NetAcceptThread(threading.Thread):

def __init__(self):

super(NetAcceptThread,self).__init__()

self.__runflag = True

self.__threadlist = []

def run(self):

"监听，每当有一个新的连接请求则创建新的线程"

self._listenfd = socket.socket()

self._listenfd.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1 )

config = ConfigData.ConfigData()

_listenAddress = config.GetLocalServerAddress()

try:

self._listenfd.bind((_listenAddress[0],int(_listenAddress[1])))

except Exception,e:

self._listenfd.close();

return MagicNum.NetAcceptc.BINDERROR

self._listenfd.listen(MagicNum.NetAcceptc.MAXLISTENNUM)

self._listenfd.setblocking(0)

_epoll = select.epoll()

_epoll.register(self._listenfd.fileno(),select.EPOLLIN)

while self.__runflag:

_events = _epoll.poll()

for fileno ,event in _events:

if fileno == self._listenfd.fileno():

c,addr = self._listenfd.accept()

s = 'Got connect from:' + str(addr) + "\n"

th = NetThread.NetThread(c.dup(),self,True)

self.__threadlist.append(th)

th.start()

c.close()

elif event & select.EPOLLHUP:

_epoll.unregister(fileno)

self.__runflag = False

break

self._listenfd.close();

def closeNetThread(self,th):

th.stop()

#th.join()

self.__threadlist.remove(th)

def stop(self):

"关闭所有线程"

while self.__threadlist:

th = self.__threadlist[0]

th.stop()

#th.join()

self.__threadlist.remove(th)

self.__runflag = False