Mercurial Hosting > luan
annotate src/luan/modules/Thread.luan @ 1322:d5739c101bd6
improve Thread
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Wed, 06 Feb 2019 01:11:12 -0700 |
parents | 70eecde81820 |
children | 8d95711f6615 |
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() |
1322 | 7 local Time = require "luan:Time.luan" |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
8 local Logging = require "luan:logging/Logging.luan" |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
9 local logger = Logging.logger "Thread" |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
10 |
301
a6bf8ff720f8
add java security
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
11 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
12 local Thread = {} |
503 | 13 |
1104 | 14 Thread.sleep = ThreadLuan.sleep |
503 | 15 |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
16 local function safe(fn) |
1308
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
17 return function() |
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
18 try { |
1241 | 19 fn |
1188
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
20 catch = function(e) |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
21 logger.error(e) |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
22 end |
1308
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
23 } |
1188
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 end |
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
26 |
1308
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
27 function Thread.fork(fn) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
28 fn = safe(fn) |
1308
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
29 ThreadLuan.fork(fn) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
30 end |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
31 |
1301
a9cc35c71eb0
go back to Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1255
diff
changeset
|
32 function Thread.schedule(delay,fn,repeating) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
33 fn = safe(fn) |
1302
5345466fa61f
fix last commit and improve stringify
Franklin Schmidt <fschmidt@gmail.com>
parents:
1301
diff
changeset
|
34 ThreadLuan.schedule(delay,fn,repeating) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
35 end |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
36 |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
37 |
1322 | 38 local forever = Time.period{years=100} |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
39 |
1322 | 40 function Thread.global_callable(name,fns,timeout) |
41 timeout = timeout or forever | |
42 local callable = ThreadLuan.globalCallable(name,fns,timeout) | |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
43 local mt = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
44 function mt.__index(_,key) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
45 return function(...) |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
46 return callable.call(key,...) |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
47 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
48 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
49 local tbl = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
50 set_metatable(tbl,mt) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
51 return tbl |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
52 end |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
53 |
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
54 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
|
55 |
1322 | 56 function Thread.global_map(name,timeout) |
57 timeout = timeout or forever | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
58 |
1322 | 59 local map = {} |
60 local fns = {} | |
61 | |
62 function fns.get(key) | |
63 return map[key] | |
64 end | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
65 |
1322 | 66 function fns.put(key,value) |
67 map[key] = value | |
68 end | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
69 |
1322 | 70 local callable = ThreadLuan.globalCallable(name,fns,timeout) |
71 local mt = {} | |
72 function mt.__index(_,key) | |
73 return callable.call("get",key) | |
74 end | |
75 function mt.__new_index(_,key,value) | |
76 return callable.call("put",key,value) | |
77 end | |
78 local tbl = {} | |
79 set_metatable(tbl,mt) | |
80 return tbl | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
81 end |
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
82 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
83 return Thread |