Mercurial Hosting > luan

annotate src/luan/modules/Thread.luan @ 1972:253f8a23e131

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
threading for swing
author Franklin Schmidt <fschmidt@gmail.com>
date Wed, 18 Jun 2025 18:54:38 -0600
parents 19de10be4c37
children
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"
1956
19de10be4c37 swing and rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 1929
diff changeset
3 local ThreadJava = require "java:java.lang.Thread"
1372
431d5bec3ca4 add Thread.new_synchronizer
Franklin Schmidt <fschmidt@gmail.com>
parents: 1366
diff changeset
4 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
5 local Luan = require "luan:Luan.luan"
f16c77ef0f4f add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 788
diff changeset
6 local error = Luan.error
1780
d3ea0380dfb6 rename Thread.fork to Thread.run
Franklin Schmidt <fschmidt@gmail.com>
parents: 1616
diff changeset
7 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
8 local set_metatable = Luan.set_metatable or error()
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
9 local Time = require "luan:Time.luan"
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
10 local Logging = require "luan:logging/Logging.luan"
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
11 local logger = Logging.logger "Thread"
794
f16c77ef0f4f add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 788
diff changeset
12
301
a6bf8ff720f8 add java security
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
13
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 794
diff changeset
14 local Thread = {}
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 321
diff changeset
15
1104
772d16c89056 add Thread.sleep()
Franklin Schmidt <fschmidt@gmail.com>
parents: 1099
diff changeset
16 Thread.sleep = ThreadLuan.sleep
1972
253f8a23e131 threading for swing
Franklin Schmidt <fschmidt@gmail.com>
parents: 1956
diff changeset
17 Thread.thread_safe_function = ThreadLuan.thread_safe_function
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 321
diff changeset
18
1956
19de10be4c37 swing and rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 1929
diff changeset
19 function Thread.current_thread_name()
19de10be4c37 swing and rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 1929
diff changeset
20 return ThreadJava.currentThread().getName()
19de10be4c37 swing and rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 1929
diff changeset
21 end
19de10be4c37 swing and rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 1929
diff changeset
22
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
23 local function safe(fn)
1308
70eecde81820 remove fn,... to improve readability
Franklin Schmidt <fschmidt@gmail.com>
parents: 1302
diff changeset
24 return function()
1520
d9a5405a3102 try statement
Franklin Schmidt <fschmidt@gmail.com>
parents: 1515
diff changeset
25 try
d9a5405a3102 try statement
Franklin Schmidt <fschmidt@gmail.com>
parents: 1515
diff changeset
26 fn()
d9a5405a3102 try statement
Franklin Schmidt <fschmidt@gmail.com>
parents: 1515
diff changeset
27 catch e
d9a5405a3102 try statement
Franklin Schmidt <fschmidt@gmail.com>
parents: 1515
diff changeset
28 logger.error(e)
d9a5405a3102 try statement
Franklin Schmidt <fschmidt@gmail.com>
parents: 1515
diff changeset
29 end
1188
9f5edbef3f55 remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents: 1166
diff changeset
30 end
9f5edbef3f55 remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents: 1166
diff changeset
31 end
1616
915cb538e2a3 start swing
Franklin Schmidt <fschmidt@gmail.com>
parents: 1578
diff changeset
32 Thread.safe = safe
1188
9f5edbef3f55 remove old web log files
Franklin Schmidt <fschmidt@gmail.com>
parents: 1166
diff changeset
33
1972
253f8a23e131 threading for swing
Franklin Schmidt <fschmidt@gmail.com>
parents: 1956
diff changeset
34 function Thread.run(fn,clean)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
35 fn = safe(fn)
1972
253f8a23e131 threading for swing
Franklin Schmidt <fschmidt@gmail.com>
parents: 1956
diff changeset
36 ThreadLuan.run(fn,clean)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
37 end
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
38
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
39 function Thread.schedule(fn,options)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
40 fn = safe(fn)
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
41 options = options or {}
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
42 ThreadLuan.schedule(fn,options)
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
43 end
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
44
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
45 function Thread.schedule_closure(init_fn,options)
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
46 local function safe_init()
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
47 return safe(init_fn())
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
48 end
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
49 options = options or {}
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
50 ThreadLuan.schedule_closure(safe_init,options)
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
51 end
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
52
1233
3fad7091b419 make Thread.safe implicit
Franklin Schmidt <fschmidt@gmail.com>
parents: 1188
diff changeset
53
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
54 local forever = Time.period{years=100}
794
f16c77ef0f4f add Parsers.json_string and Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 788
diff changeset
55
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
56 function Thread.global_callable(name,init_fn,timeout)
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
57 timeout = timeout or forever
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
58 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
59 local mt = {}
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
60 function mt.__index(_,key)
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
61 return function(...)
1159
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
62 return callable.call(key,...)
1157
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 end
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
65 local tbl = {}
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
66 set_metatable(tbl,mt)
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
67 return tbl
50879022f49d failed attempt to remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1104
diff changeset
68 end
1159
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
69
3ef883468fd0 remove Http.per_session_pages
Franklin Schmidt <fschmidt@gmail.com>
parents: 1157
diff changeset
70 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
71
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
72 function Thread.global_map(name,timeout)
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
73 local function init()
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
74 local map = {}
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
75 local fns = {}
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
76
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
77 function fns.__index(_,key)
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
78 return map[key]
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
79 end
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
80
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
81 function fns.__new_index(_,key,value)
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
82 map[key] = value
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
83 end
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
84
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
85 return fns
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
86 end
1578
c922446f53aa immutable threading
Franklin Schmidt <fschmidt@gmail.com>
parents: 1520
diff changeset
87 local mt = Thread.global_callable(name,init,timeout)
1322
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
88 local tbl = {}
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
89 set_metatable(tbl,mt)
d5739c101bd6 improve Thread
Franklin Schmidt <fschmidt@gmail.com>
parents: 1308
diff changeset
90 return tbl
1166
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
91 end
7ef40e1923b7 add back Thread.global
Franklin Schmidt <fschmidt@gmail.com>
parents: 1159
diff changeset
92
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
93
1515
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
94 local default_time_out = Time.period{minutes=10}
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
95 local run_in_lock = ThreadLuan.runInLock
1515
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
96 local get_lock = ThreadLuan.getLock
1366
ae2321a09723 improve Thread.schedule
Franklin Schmidt <fschmidt@gmail.com>
parents: 1353
diff changeset
97
1515
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
98 function Thread.synchronized(fn,key,time_out)
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
99 time_out = time_out or default_time_out
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
100 local lock = get_lock(key)
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
101 return function(...)
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
102 return run_in_lock(lock,time_out,fn,...)
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
103 end
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
104 end
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
105
78d937870762 Thread.synchronized
Franklin Schmidt <fschmidt@gmail.com>
parents: 1408
diff changeset
106
1929
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
107 function Thread.new_future(fn)
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
108 local java = ThreadLuan.newFuture(fn)
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
109 return {
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
110 java = java
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
111 get = java.get
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
112 is_done = java.isDone
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
113 }
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
114 end
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
115
31f006c64782 translation
Franklin Schmidt <fschmidt@gmail.com>
parents: 1780
diff changeset
116
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 794
diff changeset
117 return Thread