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
|
proc ::tool::define::coroutine {name corobody} {
set class [current_class]
::oo::meta::info $class set method_ensemble ${name} _preamble: [list {} [string map [list %coroname% $name] {
my variable coro_queue coro_lock
set coro %coroname%
set coroname [info object namespace [self]]::%coroname%
}]]
::oo::meta::info $class set method_ensemble ${name} coroutine: {{} {
return $coroutine
}}
::oo::meta::info $class set method_ensemble ${name} restart: {{} {
# Don't allow a coroutine to kill itself
if {[info coroutine] eq $coroname} return
if {[info commands $coroname] ne {}} {
rename $coroname {}
}
set coro_lock($coroname) 0
::coroutine $coroname {*}[namespace code [list my $coro main]]
::cron::object_coroutine [self] $coroname
}}
::oo::meta::info $class set method_ensemble ${name} kill: {{} {
# Don't allow a coroutine to kill itself
if {[info coroutine] eq $coroname} return
if {[info commands $coroname] ne {}} {
rename $coroname {}
}
}}
::oo::meta::info $class set method_ensemble ${name} main: [list {} $corobody]
::oo::meta::info $class set method_ensemble ${name} clear: {{} {
set coro_queue($coroname) {}
}}
::oo::meta::info $class set method_ensemble ${name} next: {{eventvar} {
upvar 1 [lindex $args 0] event
if {![info exists coro_queue($coroname)]} {
return 1
}
if {[llength $coro_queue($coroname)] == 0} {
return 1
}
set event [lindex $coro_queue($coroname) 0]
set coro_queue($coroname) [lrange $coro_queue($coroname) 1 end]
return 0
}}
::oo::meta::info $class set method_ensemble ${name} peek: {{eventvar} {
upvar 1 [lindex $args 0] event
if {![info exists coro_queue($coroname)]} {
return 1
}
if {[llength $coro_queue($coroname)] == 0} {
return 1
}
set event [lindex $coro_queue($coroname) 0]
return 0
}}
::oo::meta::info $class set method_ensemble ${name} running: {{} {
if {[info commands $coroname] eq {}} {
return 0
}
if {[::cron::task exists $coroname]} {
set info [::cron::task info $coroname]
if {[dict exists $info running]} {
return [dict get $info running]
}
}
return 0
}}
::oo::meta::info $class set method_ensemble ${name} send: {args {
lappend coro_queue($coroname) $args
if {[info coroutine] eq $coroname} {
return
}
if {[info commands $coroname] eq {}} {
::coroutine $coroname {*}[namespace code [list my $coro main]]
::cron::object_coroutine [self] $coroname
}
if {[info coroutine] eq {}} {
::cron::do_one_event $coroname
} else {
yield
}
}}
::oo::meta::info $class set method_ensemble ${name} default: {args {my [self method] send $method {*}$args}}
}
|
