Mercurial Hosting > luan

annotate src/luan/modules/Thread.luan @ 1366:ae2321a09723

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
improve Thread.schedule
author Franklin Schmidt <fschmidt@gmail.com>
date Mon, 17 Jun 2019 21:50:40 -0600
parents 8d95711f6615
children 431d5bec3ca4
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1353
8d95711f6615 replace java() with require "java"
Franklin Schmidt <fschmidt@gmail.com>
parents: 1322
diff changeset
1 require "java"
321
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
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
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
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 321
diff changeset
13
1104
772d16c89056 add Thread.sleep()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1099
diff changeset
14 Thread.sleep = ThreadLuan.sleep
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 321
diff changeset
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
2b5046cd7963 fix Thread safe()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1233
diff changeset
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
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
32 function Thread.schedule(fn,options)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
33 fn = safe(fn)
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
34 options = options or {}
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
35 ThreadLuan.schedule(fn,options)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
36 end
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
37
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
38
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
39 local forever = Time.period{years=100}
794
f16c77ef0f4f add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 788
diff changeset
40
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
41 function Thread.global_callable(name,fns,timeout)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
42 timeout = timeout or forever
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
43 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
44 local mt = {}
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
45 function mt.__index(_,key)
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
46 return function(...)
1159
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
47 return callable.call(key,...)
1157
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 end
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
50 local tbl = {}
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
51 set_metatable(tbl,mt)
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
52 return tbl
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
53 end
1159
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
54
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
55 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
56
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
57 function Thread.global_map(name,timeout)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
58 timeout = timeout or forever
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
59
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
60 local map = {}
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
61 local fns = {}
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
62
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
63 function fns.get(key)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
64 return map[key]
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
65 end
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
66
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
67 function fns.put(key,value)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
68 map[key] = value
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
69 end
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
70
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
71 local callable = ThreadLuan.globalCallable(name,fns,timeout)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
72 local mt = {}
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
73 function mt.__index(_,key)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
74 return callable.call("get",key)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
75 end
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
76 function mt.__new_index(_,key,value)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
77 return callable.call("put",key,value)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
78 end
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
79 local tbl = {}
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
80 set_metatable(tbl,mt)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
81 return tbl
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
82 end
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
83
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
84
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
85 local backup_lock = ThreadLuan.backupLock.readLock()
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
86 local run_in_lock = ThreadLuan.runInLock
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
87
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
88 function Thread.run_for_backup(fn)
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
89 return run_in_lock(backup_lock,fn)
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
90 end
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
91
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
92
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 794
diff changeset
93 return Thread