parallel_mandel.py の履歴(No.2)

  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
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

-
|
|
!
 
 
 
-
|
!
 
-
!
 
 
 
 
 
 
 
 
 
 
 
-
!
 
 
 
 
-
!
 
-
!
-
!
 
-
|
!
 
 
 
 
-
!
 
-
!
 
-
!
 
 
 
 
 
 
 
 
-
!
 
 
 
 
 
 
-
!
 
-
!
 
 
 
 
 
 
 
 
-
!
 
-
!
-
!
 
-
!
 
 
 
-
!
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
-
|
!
 
 
 
 
 
-
!
 
 
 
 

# parallel_mandel.py
# -*- coding: utf-8 -*-
#
import socket
import threading
import time
import sys
#import matplotlib.pyplot as plt
#import numpy as np
import tkinter as tk
 
# 通信クラス
 
 
class Com:
    HOST = ''
    PORT = 9998
    clxa = []  # 複数のclientのsocketとアドレスの組を格納するリスト
    return_from_worker = []
    server_receiver = None
    client_receiver = None
 
    def start_server(self):
        handle_thread = threading.Thread(target=self.server_thread, args=())
        # 生成した handle_threadの実行開始(start)
        handle_thread.start()
 
    def server_thread(self):
        print("start server socket")
        self.pid = 0
        # socket.socket()...接続先のsocketを作成
        self.soc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.soc.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        # sock.binde ...socket をこのホスト('')のIPアドレスとPortに結合
        self.soc.bind((self.HOST, self.PORT))
        # sock.listen(10)...clientからの接続を待つ。10は最大の接続要求可能数
        self.soc.listen(10)
        while True:
            # sock.accept()...client から接続があると、クライアントと接続する
            # socket conと接続元IP address を返す
            con, address = self.soc.accept()
            clx = (con, address, self.pid)  # clxに tuple (con, address,pid)を代入
            self.clxa.append(clx)  # clxaにclxを追加
            print("[connect]{}".format(address))
            self.pid = self.pid+1
            # clientと送受信するためのthread, handler を生成。
            handle_thread = threading.Thread(
                target=self.server_handler, args=(clx,))
            # 生成した handle_threadの実行開始(start)
            handle_thread.start()
 
    # client からsocketを通じてstreamの入力を行うthreadのhander
    def server_handler(self, clx):
        print("at server, connected, start handler")
        con = clx[0]  # clx[0] は con(socket),
        address = clx[1]  # clx[1] は address
        pid = clx[2]  # cls[2] は processor id
        while True:
            try:
                data = con.recv(1024)  # socket con から最大1024byte 受信
                recv_line = data.decode("utf-8")
                #print("[receive]{} - {}".format(address, recv_line))
                self.server_receiver.server_rx(recv_line, pid)
            except socket.error:  # socketにエラーが発生したとき
                con.close()  # socketをclose
                break
            except:
                print("server_handler receive error.")
                break
    #
 
    def send_ith_worker(self, line, i):
        # print("send_ith_worker("+line+","+str(i)+")")
        cx = self.clxa[i]
        try:
            cx[0].send(line.encode('utf-8'))
        except:
            print("send_ith_worker error")
 
    def start_client(self, host):
        print("start client socket, connect, host="+host)
        try:
            # socket.socket ... socket を作成し、socに代入
            self.soc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.soc.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
            # IPアドレスがhostのserver socketにsocを接続
            self.soc.connect((host, self.PORT))
            # 受信担当の関数handlerを物threadでうごかすhandle_threadを生成。
            self.handle_thread = threading.Thread(
                target=self.client_handler, args=(self.soc,))
            # handle_threadをstart
            self.handle_thread.start()
        except:  # 接続時にエラーがあった場合の処理
            print("connect error.")
 
    # 受信の処理。送信threadとは別に、並行して処理を行う。
    def client_handler(self, soc):
        print("at client, connected, start handler")
        while True:
            try:
                data = soc.recv(1024)
                line = data.decode("utf-8")
                print("[receive]- {}".format(line))
                (self.client_receiver).worker_rx(line)
            except socket.error:
                soc.close()
                break
            except:
                print("client_handler, receive error.")
 
    def get_client_number(self):
        return len(self.clxa)
 
    def send_to_server(self, line):
        self.soc.send(bytes(line, "utf-8"))
 
    #
    # server, clientにおいて、受け取ったデータを処理するreceiverの設定
    def set_server_receiver(self, rec):
        self.server_receiver = rec
 
    def set_client_receiver(self, rec):
        self.client_receiver = rec
 
    #
    def close_all(self):
        for cx in self.clxa:
            cx[0].close()