執行緒池

首先怎麼理解執行緒池呢？
比如有十臺機器（執行緒池的大小），現在要加工一百件產品（要執行的任務）。
一件產品加工完之後（任務完成）機器（執行緒）開始加工下一件產品（新增任務到執行緒池）。
因為不能有100件產品需要加工就買100臺機器。也不能因為到最後要加工不到十件產品讓十臺機器都開著。
那麼就應該讓機器如果發現沒有產品需要加工的時候就停止執行。

將產品按照順序排列。十臺機器開始加工，機器效能可能不一樣，產品也可能存在不一樣，所以加工的時間也不一致。
有的機器可能快一點。只要一臺機器加工完了當前產品，那麼就從剩下的產品佇列中取產品。直到發現再沒有產品可取了。
那麼就停止當前機器。

有了上面的解釋執行緒池就好理解多了，有一堆任務需要開闢執行緒去執行，但是不能一下開闢那麼多執行緒，需要有個限額，所以執行緒池就來了。利用佇列，將需要執行的任務放到佇列裡面，然後再呼叫執行緒池從佇列裡面取任務執行。

怎麼去在佇列執行完去關閉執行緒呢。
這裡需要用到上下文管理

@contextlib.contextmanager
def _workerState(self, stateList, workerThread):
stateList.append(workerThread)
try:
yield
finally:
stateList.remove(workerThread)


paramiko是第三方模組，比較強大，可以幫助我們很輕易的建立ssh連線。

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# created by hansz
import select
import paramiko
import tty
import sys
user= "hansz"
passwd= "hansz"
# host_list =["192.168.17.137"]
port = 22
host = "192.168.17.137"
 

# 用的是不同的類。
# 第一種方式 直接建立SSHClient(），其實也是封裝了Transsport，只能用於執行命令
# ssh = paramiko.SSHClient()# 短暫連線，執行完就斷
# ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# ssh.connect(host, port, user, passwd)

# 第二種，Transport，執行命令用這種，上傳下載檔案也可以用這種。
transport = paramiko.Transport((host,22))
# transport.connect(username=user,password=passwd)

# 或者
transport.start_client()
transport.auth_password(user,passwd)

# 要執行命令的話可以給ssh._transport賦值。
# ssh = paramiko.SSHClient()
# ssh._transport = transport
# stdin,stdout,stderr = ssh.exec_command("ls")
# print stdout.read()

# 上傳下載檔案
# sftp = paramiko.SFTPClient.from_transport(transport)
# sftp.put("haha","aa")

# always connet
channel = transport.open_session()
channel.get_pty()
channel.invoke_shell()

import termios
import tty
oldtty = termios.tcgetattr(sys.stdin)
try:
    tty.setraw(sys.stdin.fileno())
    channel.settimeout(0.0)
    while True:
        readable, writeable, error = select.select([channel, sys.stdin, ],[],[],1)

        # if it change ,select will catch this
        if channel in readable:
            try:
                x = channel.recv(1024)
                if len(x) == 0:
                    print "EOF"
                    break
                sys.stdout.write(x)
                sys.stdout.flush()
            except socket.timeout:
                pass
        if sys.stdin in readable:
            # read should be 1
            x = sys.stdin.read(1)
            if len(x) == 0:
                break
            channel.send(x)
finally:
    termios.tcsetattr(sys.stdin,termios.TCSADRAIN,oldtty)

transport.close()