Hey guys I want to make a Queue which holds command I tried

Question

Hey guys I want to make a Queue which holds command I tried to use `ConcurrentLinkedQueue` with `<http Dispatcher IO|Dispatcher IO>` and `synchronized` with `ConcurrentLinkedQueue` The code is working fine but very slow responding the data Anyone guide me on this How to improve response time

KotlinLeaner · Answer

from the class in my sample project ```private fun setupQueuePolling viewModelScope launch Log e TAG Starting Polling while true synchronized commandQueue if commandQueue isEmpty commandQueue poll let qItem gt qItem This is input ```

KotlinLeaner · Answer

You can find whole class in here <https github com vivek modi QueueApplication blob master app src main java com example queueapplication QueueViewModel kt|QueueViewModel>

kevin.cianfarini · Answer

Use a Channel

KotlinLeaner · Answer

But how can you help me on this

Casey Brooks · Answer

A Channel is a Queue built on coroutines machinery This <https kotlinlang org docs channels html|docs page> should help you get an understanding of how to use a Channel to build your queue

KotlinLeaner · Answer

Is there similar post releated to my work

Casey Brooks · Answer

You were asking how to make a queue and how to make it work nicely with coroutines But the problem is that I don t think your whole `setupQueuePolling ` isn t quite doing what you expect `ConcurrentLinkedQueue` and `synchronized ` are Java concurrency mechanisms which don t play nicely with coroutines so we suggested an alternative which does work with coroutines Your original question stated I tried to use which suggested that you weren t completely bought into that solution yet Is your main question how to build a queue that runs on coroutines or help diagnosing why your existing queue is slow It s difficult to know what is making it slow without knowing exactly what you mean by slow But if you re still just exploring this queue mechanism more generally I would recommend replacing your `ConcurrentLinkedQueue` with a `Channel` first and then see if the slowness improves

KotlinLeaner · Answer

Hi Casey Thank you for great explanation I am building an application in which user can read BPM data in mobile I was reading in some posts that I need to build a queue for that it run at a time and hold next command in queue until it finish the first job I used some piece of code from the <https github com weliem blessed android coroutines|library> I want to check my existing queue why is it slow if anything which is more efficient then `ConcurrentLinkedQueue` then definitely I ll try that TBH I don t know queue that runs with coroutines will help me on my issue or not

uli · Answer

You are in channel < C1CFAFJSK|coroutines> though

KotlinLeaner · Answer

Yes I am in the channel

uli · Answer

you asked in < C1CFAFJSK|coroutines> so you ll get coroutine answers

KotlinLeaner · Answer

Yes I want the way in < C1CFAFJSK|coroutines> I just explain in above what I need to achieve Sorry If I did anything wrong in here

uli · Answer

Have you looked into the class `Channel`that the coroutines library provides Otherwise please do so Channels provide a coroutine based queue implementation with probably better performance characteristics then mixing java threadding in

KotlinLeaner · Answer

Yes I am learning basic in `Channel` If any doubt I ll ask in here Thanks for great advice