Mercurial Hosting > luan
annotate src/luan/modules/Thread.luan @ 1802:ca98dee04e08 default tip
add Parsers.json_null
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sun, 21 Apr 2024 21:25:15 -0600 |
parents | d3ea0380dfb6 |
children |
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" |
1372
431d5bec3ca4
add Thread.new_synchronizer
Franklin Schmidt <fschmidt@gmail.com>
parents:
1366
diff
changeset
|
3 local ReentrantLock = require "java:java.util.concurrent.locks.ReentrantLock" |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
4 local Luan = require "luan:Luan.luan" |
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
5 local error = Luan.error |
1780
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
6 local new_error = Luan.new_error or error() |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
7 local set_metatable = Luan.set_metatable or error() |
1322 | 8 local Time = require "luan:Time.luan" |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
9 local Logging = require "luan:logging/Logging.luan" |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
10 local logger = Logging.logger "Thread" |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
11 |
301
a6bf8ff720f8
add java security
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
12 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
13 local Thread = {} |
503 | 14 |
1104 | 15 Thread.sleep = ThreadLuan.sleep |
503 | 16 |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
17 local function safe(fn) |
1308
70eecde81820
remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents:
1302
diff
changeset
|
18 return function() |
1520 | 19 try |
20 fn() | |
21 catch e | |
22 logger.error(e) | |
23 end | |
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 |
1616 | 26 Thread.safe = safe |
1188
9f5edbef3f55
remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents:
1166
diff
changeset
|
27 |
1780
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
28 function Thread.run(fn) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
29 fn = safe(fn) |
1780
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
30 ThreadLuan.run(fn) |
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
31 end |
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
32 |
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
33 function Thread.fork(fn) |
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
34 logger.error(new_error("Thread.fork is obsolete")) |
d3ea0380dfb6
rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents:
1616
diff
changeset
|
35 Thread.run(fn) |
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 |
1366
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
38 function Thread.schedule(fn,options) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
39 fn = safe(fn) |
1366
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
40 options = options or {} |
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
41 ThreadLuan.schedule(fn,options) |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
42 end |
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
43 |
1578 | 44 function Thread.schedule_closure(init_fn,options) |
45 local function safe_init() | |
46 return safe(init_fn()) | |
47 end | |
48 options = options or {} | |
49 ThreadLuan.schedule_closure(safe_init,options) | |
50 end | |
51 | |
1233
3fad7091b419
make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
1188
diff
changeset
|
52 |
1322 | 53 local forever = Time.period{years=100} |
794
f16c77ef0f4f
add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
788
diff
changeset
|
54 |
1578 | 55 function Thread.global_callable(name,init_fn,timeout) |
1322 | 56 timeout = timeout or forever |
1578 | 57 local callable = ThreadLuan.globalCallable(name,init_fn,timeout) |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
58 local mt = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
59 function mt.__index(_,key) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
60 return function(...) |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
61 return callable.call(key,...) |
1157
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
62 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
63 end |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
64 local tbl = {} |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
65 set_metatable(tbl,mt) |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
66 return tbl |
50879022f49d
failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1104
diff
changeset
|
67 end |
1159
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
68 |
3ef883468fd0
remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents:
1157
diff
changeset
|
69 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
|
70 |
1322 | 71 function Thread.global_map(name,timeout) |
1578 | 72 local function init() |
73 local map = {} | |
74 local fns = {} | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
75 |
1578 | 76 function fns.__index(_,key) |
77 return map[key] | |
78 end | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
79 |
1578 | 80 function fns.__new_index(_,key,value) |
81 map[key] = value | |
82 end | |
1166
7ef40e1923b7
add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents:
1159
diff
changeset
|
83 |
1578 | 84 return fns |
1322 | 85 end |
1578 | 86 local mt = Thread.global_callable(name,init,timeout) |
1322 | 87 local tbl = {} |
88 set_metatable(tbl,mt) | |
89 return tbl | |
1166
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 |
1366
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
92 |
1515 | 93 local default_time_out = Time.period{minutes=10} |
1366
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
94 local run_in_lock = ThreadLuan.runInLock |
1515 | 95 local get_lock = ThreadLuan.getLock |
1366
ae2321a09723
improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
96 |
1515 | 97 function Thread.synchronized(fn,key,time_out) |
98 time_out = time_out or default_time_out | |
99 local lock = get_lock(key) | |
100 return function(...) | |
101 return run_in_lock(lock,time_out,fn,...) | |
102 end | |
103 end | |
104 | |
105 | |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
794
diff
changeset
|
106 return Thread |