Sarangnamu.net June 17, 2003
Observable.fromFuture
Async ÇÑ °ªÀ» Observable ·Î Àü´Þ ¹Þ°í ½ÍÀº °æ¿ì°¡ Á¾Á¾ Àִµ¥ ¾î¶»°Ô Çϳª ÇÏ´Ù°¡ ã¾Æº¸´Ï ¾Æ·¡¿Í °°ÀÌ Future ¸¦ ÀÌ¿ëÇØ Àü´Þ ¹Þ´Â ¹æ¹ýÀ» ã¾Ò´Ù.
Observable.fromFuture(Executors.newSingleThreadExecutor()
.submit(() -> getList(activity)));
Executors ÀÇ newSingleThreadExecutor °¡ Async ÇÏ°Ô µ¿ÀÛÇÏ°Ô µÇ°í submit À¸·Î ¿øÇÏ´Â °á°ú¸¦ Observable ¿¡ Àü´ÞÇÒ ¼ö ÀÖ´Ù.
¹ø¿Ü·Î ¶á±Ý ¾øÀÌ ÀÎÅͳݿ¡¼ º» ÄÚµå Áß¿¡ ½Ó¹ÚÇÏ°Ô kotlin ¿¡¼ Executors.newSingleThreadExecutor() ¸¦ ÀÌ¿ëÇØ
ioThread {
// TODO
}
ÀÌ·¸°Ô ¾²´ø°Ô °©Àڱ⠻ý°¢³µ´Ù
private val IO_EXECUTOR = Executors.newSingleThreadExecutor()
/**
* Utility method to run blocks on a dedicated background thread, used for io/database work.
*/
fun ioThread(f : () -> Unit) {
IO_EXECUTOR.execute(f)
}
coder : aucd29,
twitter : @aucd29
Today : 2,083
Total : 8,057,498
[RSS]