package Ġruntime . workers . worker 3 Ċ Ċ import Ġkotlin . test .* Ċ Ċ import Ġkon an . worker .* Ċ Ċ data Ġclass ĠWorker Argument ( val Ġint Param : ĠInt , Ġval Ġstring Param : ĠString ) Ċ data Ġclass ĠWorker Result ( val Ġint Result : ĠInt , Ġval Ġstring Result : ĠString ) Ċ Ċ @ Test Ġfun Ġrun Test () Ġ{ ĊĠĠĠ Ġmain ( empty Array ()) Ċ } Ċ Ċ fun Ġmain ( args : ĠArray < String >) Ġ{ ĊĠĠĠ Ġval Ġworker Ġ= Ġstart Worker () ĊĠĠĠ Ġval Ġs Ġ= Ġ" zz z ${ args . size . toString () }" ĊĊĠĠĠ Ġval Ġfuture Ġ= Ġtry Ġ{ ĊĠĠĠĠĠĠĠ Ġworker . schedule ( Transfer Mode . CHECK ED , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ ĠWorker Argument ( 4 2 , Ġs ) Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ Ġinput Ġ-> ĠWorker Result ( input . int Param , Ġinput . string Param Ġ+ Ġ" Ġresult ") Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ġcatch Ġ( e : ĠIllegalStateException ) Ġ{ ĊĠĠĠĠĠĠĠ Ġnull ĊĠĠĠ Ġ} ĊĠĠĠ Ġif Ġ( future Ġ!= Ġnull ) ĊĠĠĠĠĠĠĠ Ġprintln (" Fail Ġ 1 ") ĊĠĠĠ Ġif Ġ( s Ġ!= Ġ" zz z 0 ") Ġprintln (" Fail Ġ 2 ") ĊĠĠĠ Ġworker . request Termination (). consume Ġ{ Ġ_ Ġ-> Ġ} ĊĠĠĠ Ġprintln (" OK ") Ċ }