bluelake/multithrdtmp.py at master · lancelee82/bluelake · GitHub

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
"""
Multi-thead and pygame
"""

import random
import math
import time

import Queue

from starfish import pygm
from starfish import consts

from starfish import multithrd
from starfish import snowspt
from starfish import sptdraw


class ThrdTime(multithrd.PgThrd):
    def __init__(self, q=None):
        super(ThrdTime, self).__init__(q)

        self.t_last = None

    def do_once(self):
        t = int(time.time())
        if t % 2 == 0 and t != self.t_last:
            #print t
            self.q.put(t)
            self.t_last = t


class MTScene(pygm.PyGMScene):
    def __init__(self, q, *args, **kwargs):
        super(MTScene, self).__init__(*args, **kwargs)

        self.q = q

        self.lb1 = pygm.SptLbl(0, c=consts.WHITE)
        self.lb1.rect.top = 460
        self.lb1.rect.left = 60
        self.disp_add(self.lb1)

        self.sn1 = snowspt.SptSnow((800, 550), 100)
        self.disp_add(self.sn1)


        def f(x):
            #return x ** 3 + x ** 2 + x
            #return x ** 2 + x
            return (x / 2.0) * math.sin(x / 100.0) + 200.0
        self.drfn1 = sptdraw.SptDrawFunc((400, 400), f, (0, 400), 6)
        self.disp_add(self.drfn1)

    def refresh(self, fps_clock, *args, **kwargs):
        if not self.q.empty():  # or use self.q.get_nowait()
            t = self.q.get()
            #print t
            if t:
                self.lb1.lbl_set(t)


class GMMultithrd(pygm.PyGMGame):
    def __init__(self, title, winw, winh, *args, **kwargs):
        super(GMMultithrd, self).__init__(title, winw, winh)

        self.bk = pygm.SptImg('data/img_bk_1.jpg')
        self.bk.rect.top = -230
        self.disp_add(self.bk)

        self.q = Queue.Queue()

        self.scn1 = MTScene(self.q)
        self.disp_add(self.scn1)

        # add a time thread
        self.thrd_tm = ThrdTime(self.q)
        self.thrd_add(self.thrd_tm)
        self.thrd_tm.start()


def main():
    lk = GMMultithrd('Mulit Thrd', 800, 550)
    lk.mainloop()


if __name__ == '__main__':
    main()