Mercurial Hosting > luan
annotate src/luan/modules/Thread.luan @ 1255:4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Mon, 03 Sep 2018 06:13:55 -0600 |
parents | 2b5046cd7963 |
children | a9cc35c71eb0 |
rev | line source |
---|---|
321
7f7708e8fdd4
remove import statement
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
320
diff
changeset
|
1 java() |
7f7708e8fdd4
remove import statement
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
320
diff
changeset
|
2 local ThreadLuan = require "java:luan.modules.ThreadLuan" |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
3 local Luan = require "luan:Luan.luan" |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
4 local error = Luan.error |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
5 local set_metatable = Luan.set_metatable or error() |
1188
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
6 local try = Luan.try or error() |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
7 local Logging = require "luan:logging/Logging.luan" |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
8 local logger = Logging.logger "Thread" |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
9 |
301
a6bf8ff720f8
add java security
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
10 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
11 local Thread = {} |
503 | 12 |
1104 | 13 Thread.sleep = ThreadLuan.sleep |
503 | 14 |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
15 local function safe(fn) |
1241 | 16 return function(...) |
17 try( { | |
18 fn | |
1188
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
19 catch = function(e) |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
20 logger.error(e) |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
21 end |
1241 | 22 }, ... ) |
1188
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
23 end |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
24 end |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
25 |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
26 function Thread.fork(fn,...) |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
27 fn = safe(fn) |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
28 ThreadLuan.fork(fn,...) |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
29 end |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
30 |
1255
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
31 function Thread.once(delay,fn,...) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
32 fn = safe(fn) |
1255
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
33 ThreadLuan.schedule(delay,false,fn,...) |
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
34 end |
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
35 |
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
36 function Thread.repeating(delay,fn,...) |
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
37 fn = safe(fn) |
4f571a974132
replace Thread.schedule with Thread.once and Thread.repeating
Franklin Schmidt <fschmidt@gmail.com>
parents:
1241
diff
changeset
|
38 ThreadLuan.schedule(delay,true,fn,...) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
39 end |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
40 |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
41 |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
42 --[[ |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
43 Thread.global = {} -- shared across threads |
1099
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
44 local map = ThreadLuan.GlobalMap.new() |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
45 local global_mt = {} |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
46 set_metatable(Thread.global,global_mt) |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
47 |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
48 function global_mt.__index(_,key) |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
49 return map.get(key) |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
50 end |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
51 |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
52 function global_mt.__new_index(_,key,value) |
1099
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
53 map.put(key,value) |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
54 end |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
55 |
1099
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
56 function Thread.get_global_timeout() |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
57 return map.timeout |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
58 end |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
59 |
1099
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
60 function Thread.set_global_timeout(timeout) |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
61 map.timeout = timeout |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
62 end |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
63 |
1099
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
64 function Thread.global_put(key,value) |
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
65 return map.put(key,value) |
a5406f076726
improve Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
66 end |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
67 ]] |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
68 |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
69 function Thread.global_callable(name,timeout,fns) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
70 local callable = ThreadLuan.globalCallable(name,timeout,fns) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
71 local mt = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
72 function mt.__index(_,key) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
73 return function(...) |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
74 return callable.call(key,...) |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
75 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
76 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
77 local tbl = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
78 set_metatable(tbl,mt) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
79 return tbl |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
80 end |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
81 |
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
82 Thread.remove_global_callable = ThreadLuan.removeGlobalCallable |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
83 |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
84 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
85 local map = {} |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
86 local fns = {} |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
87 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
88 function fns.get(key) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
89 return map[key] |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
90 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
91 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
92 function fns.put(key,value) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
93 map[key] = value |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
94 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
95 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
96 Thread.global = {} -- shared across threads |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
97 local global_mt = {} |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
98 set_metatable(Thread.global,global_mt) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
99 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
100 function global_mt.__index(_,key) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
101 return global_mt.fns.get(key) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
102 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
103 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
104 function global_mt.__new_index(_,key,value) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
105 global_mt.fns.put(key,value) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
106 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
107 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
108 function Thread.set_global_timeout(timeout) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
109 global_mt.fns = Thread.global_callable("Thread.global",timeout,fns) |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
110 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
111 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
112 Thread.set_global_timeout(60000) -- one minute |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
113 |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
114 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
115 return Thread |