DBot/kommons
DBot/kommons
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MailboxExecutorService docs

Browse Source
This commit is contained in:
DBotThePony 2024-02-03 23:16:46 +07:00
parent 8a9da77006
commit 9d9af68d10
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/kotlin/ru/dbotthepony/kommons/util/MailboxExecutorService.kt
View File

@ -36,6 +36,12 @@ private fun <E : Comparable<E>> LinkedList<E>.enqueue(value: E) {
} }
} }
/**
* [ScheduledExecutorService] which act as a mailbox, [executeQueuedTasks] must be called from main thread.
*
* [submit], [execute], etc can be called on any thread. If any of enqueueing methods are called on the same thread
* as where [executeQueuedTasks] was called, executes provided lambda immediately and returns completed future.
*/
class MailboxExecutorService(thread: Thread = Thread.currentThread()) : ScheduledExecutorService { class MailboxExecutorService(thread: Thread = Thread.currentThread()) : ScheduledExecutorService {
@Volatile @Volatile
var thread: Thread = thread var thread: Thread = thread