* limitations under the License.
 */

package org.gradle.kotlin.dsl.concurrent

import kotlin.concurrent.thread


/**
 * A thread that comes back to life when [poke]d.
 */
internal
class ResurrectingThread(val name: String, val block: () -> Unit) {

    private
    var thread: Thread? = null

    /**
     * Checks if the thread is alive, resurrecting it if it's not.
     */

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.kotlin.dsl.resolver

import org.gradle.kotlin.dsl.concurrent.ResurrectingThread
import org.gradle.kotlin.dsl.tooling.models.KotlinBuildScriptModel

import kotlin.coroutines.Continuation
import kotlin.coroutines.suspendCoroutine


private

            consumer.poke()
            return true
        }
        return false
    }

    private
    val q = ArrayBlockingQueue<T>(64)

    private
    var consumer = ResurrectingThread(name = name) {
        loop(::poll)
    }

    private
    fun poll(): T? = q.poll(pollTimeoutMillis, TimeUnit.MILLISECONDS)
}


private
const val offerTimeoutMillis = 50L


internal