Mercurial Hosting > luan

comparison src/luan/modules/Thread.luan @ 1780:d3ea0380dfb6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rename Thread.fork to Thread.run
author Franklin Schmidt <fschmidt@gmail.com>
date Wed, 30 Aug 2023 14:40:45 -0600
parents 915cb538e2a3
children
comparison
equal deleted inserted replaced
1779:96dbbdf1e368 1780:d3ea0380dfb6
1 require "java" 1 require "java"
2 local ThreadLuan = require "java:luan.modules.ThreadLuan" 2 local ThreadLuan = require "java:luan.modules.ThreadLuan"
3 local ReentrantLock = require "java:java.util.concurrent.locks.ReentrantLock" 3 local ReentrantLock = require "java:java.util.concurrent.locks.ReentrantLock"
4 local Luan = require "luan:Luan.luan" 4 local Luan = require "luan:Luan.luan"
5 local error = Luan.error 5 local error = Luan.error
6 local new_error = Luan.new_error or error()
6 local set_metatable = Luan.set_metatable or error() 7 local set_metatable = Luan.set_metatable or error()
7 local Time = require "luan:Time.luan" 8 local Time = require "luan:Time.luan"
8 local Logging = require "luan:logging/Logging.luan" 9 local Logging = require "luan:logging/Logging.luan"
9 local logger = Logging.logger "Thread" 10 local logger = Logging.logger "Thread"
10 11
22 end 23 end
23 end 24 end
24 end 25 end
25 Thread.safe = safe 26 Thread.safe = safe
26 27
28 function Thread.run(fn)
29 fn = safe(fn)
30 ThreadLuan.run(fn)
31 end
32
27 function Thread.fork(fn) 33 function Thread.fork(fn)
28 fn = safe(fn) 34 logger.error(new_error("Thread.fork is obsolete"))
29 ThreadLuan.fork(fn) 35 Thread.run(fn)
30 end 36 end
31 37
32 function Thread.schedule(fn,options) 38 function Thread.schedule(fn,options)
33 fn = safe(fn) 39 fn = safe(fn)
34 options = options or {} 40 options = options or {}