#coding=utf-8

import time

import base64

import getopt

import sys

import threading

import random

import string

import os

def base64_cal():

    str = 'admin'

    str = str.encode('utf-8')

    # 加密

    bs64 = base64.b64encode(str)

    # 解密

    debs64 = base64.b64decode(bs64)

    print(debs64.decode("utf-8"))

    # base32bit加密

    bs32 = base64.b32encode(str)

    debs32 = base64.b32decode(bs32)

    print(debs32.decode("utf-8"))

def enterParams():

    opts, args = getopt.getopt(sys.argv[1:], '-h-c:f:', ['help', 'concurrent=', 'file='])

    concurrent_data=None

    filename=None

    for opt_name, opt_value in opts:

        print(opt_name,opt_value)

        if opt_name in ('-h', '--help'):

            usage()

            sys.exit()

        if opt_name in ('-c', '--concurrent'):

            if type(opt_value).__name__=='str':

                concurrent_data=opt_value

        if opt_name in ('-f', '--file'):

                filename = opt_value

            # else:

            #     # return None

            #     raise TypeError("enter param {} not file's path".format(opt_value))

        return concurrent_data,filename

def usage():

    str="--help:\n\t-c : concurrent TotalData\n\t -f: filename's path\n--example:" \

        "\n\tpython testfile.py -c 1000000 -file=./res/testPython.txt"

    print(str)

class ConcurrentIdSample(threading.Thread):

    def __init__(self,func,args=()):

        self.func=func

        self.args=args

        threading.Thread.__init__(self)

    def run(self):

        self.result = self.func(*self.args)

    def get_result(self):

        try:

            return self.result

        except Exception:

            return None

def func(*args):

    # print(time.asctime())

    return ''.join(random.sample(string.hexdigits,random.randint(*args)))

def concurrent_execute(concurrent_data):

    pool=[]

    samplesList=[]

    for i in range(concurrent_data):

        thread_sample=ConcurrentIdSample(func,(16,20))

        pool.append(thread_sample)

        thread_sample.start()

    for thread in pool:

        thread.join()

        samplesList.append(thread.get_result())

    return samplesList

def outPut():

    st=time.time()

    concurrent_data,filename=enterParams()

    res=concurrent_execute(concurrent_data)

    end=time.time()

    during=end-st

    print(len(res),"\nmake {} datas time cost {}".format(concurrent_data,during),'\n')

if __name__ == '__main__':

    enterParams()