matplotlib数据实时更新实时显示

import matplotlib.pyplot as plt
import matplotlib.animation
import numpy as np
import pymysql
import time


import matplotlib.pyplot as plt
import numpy as np
import threading
import sys
from random import random, randrange
from time import sleep

'''
绘制2x2的画板
可设置窗口标题和4个子图标题
可更新曲线数据
'''
quit_flag = False # 退出标志
class Plot2_2(object):
    """ 2x2的画板 """
    def __init__(self, wtitle='Figure', p1title='1', p2title='2', p3title='3',p4title='4'):
        self.sub_title = [p1title, p2title, p3title, p4title] # 4个子图的标题
        self.fig, self.ax = plt.subplots() # 创建2X2子图

        # self.fig.subplots_adjust(wspace=0.3, hspace=0.3) # 设置子图之间的间距
        # self.fig.canvas.set_window_title(wtitle) # 设置窗口标题
        # 子图字典，key为子图的序号，value为子图句柄
        # self.axdict = {0: self.ax[0, 0], 1: self.ax[0, 1], 2: self.ax[1, 0], 3: self.ax[1, 1]}

    def socSQL(self):
        self.conn = pymysql.connect(host='localhost', port=3306, db='soc9527', user='root', password='root', charset='utf8')
        self.cur = self.conn.cursor()
        sql = ''' select * from soc '''
        count = self.cur.execute(sql)
        ret = self.cur.fetchall()
        self.cur.close()
        self.conn.close()
        time.sleep(3)

        idlist = []
        rSocLlist = []
        rSocRlist = []
        rSocBlist = []
        for i in ret:
            idlist.append(i[0])
            rSocLlist.append(i[1])
            rSocRlist.append(i[2])
            rSocBlist.append(i[3])
        return {'id': idlist, 'rSocL': rSocLlist, 'rSocR': rSocRlist, 'rSocB': rSocBlist}

    def showPlot(self):
        """ 显示曲线 """
        plt.show()

    def setPlotStyle(self):
        """ 设置子图的样式，这里仅设置了标题 """
        plt.xlabel("id")
        plt.ylabel("rSocL")
        plt.title("电量")

    def updatePlot(self, x, y):
        """
        更新指定序号的子图
        :param index: 子图序号
        :param x: 横轴数据
        :param y: 纵轴数据
        :return:
        """
        # X轴数据必须和Y轴数据长度一致
        if len(x) != len(y):
            ex = ValueError("x and y must have same first dimension")
            raise ex
        plt.cla() # 清空子图数据
        plt.plot(x, y) # 绘制最新的数据
        self.setPlotStyle() # 设置子图样式
        if min(x) < max(x):
            plt.xlim(min(x), max(x)) # 根据X轴数据区间调整X轴范围
        plt.draw()
        print("%s end" % sys._getframe().f_code.co_name)

def updatePlot(plot):
    """
    模拟收到实时数据，更新曲线的操作
    :param plot: 曲线实例
    :return:
    """
    print("Thread: %s" % threading.current_thread().getName())
    count = 0
    global quit_flag
    print("quit_flag[%s]" % str(quit_flag))

    while True:
        if quit_flag:
            print("quit_flag[%s]" % str(quit_flag))
            break
        count += 1
        print("count#%d" % count)
        ret = plot.socSQL()
        print(">>>>>>>>>", ret['rSocL'])
        x = [i for i in ret['id']]
        y = [int(i) for i in ret['rSocL']]
        plot.updatePlot(x, y)
        sleep(random() * 3)

def main():
    p = Plot2_2() # 创建一个2X2画板
    t = threading.Thread(target=updatePlot, args=(p,)) # 启动一个线程更新曲线数据
    t.start()
    p.showPlot() # showPlot方法会阻塞当前线程，直到窗口关闭
    print("plot close")
    global quit_flag
    quit_flag = True # 通知更新曲线数据的线程退出
    t.join()
    print("Thread: %s end" % threading.current_thread().getName())

if __name__ == '__main__':
    main()