--- /dev/null
+package com.wha.modsynth_test;
+
+import concurrent.ops._
+
+import com.wha.modsynth.RingBuffer
+
+object TestRingBuffer {
+ def kill(delay: Int) = new java.util.Timer().schedule(
+ new java.util.TimerTask {
+ override def run() = {
+ println("[killed]")
+ System.exit(0)
+ }
+ },
+ delay) // in milliseconds
+
+ def main(args: Array[String]) {
+ val buf = new RingBuffer(100)
+ var cnt = 100.0f
+ def produceString = { cnt }
+ def consumeString(ss: Float) = println(ss)
+ spawn {
+ while (true) {
+ val sig = 100.0f
+ val fx = buf.get
+ println (sig + fx * 0.5)
+ buf.put(sig + fx * 0.1f)
+ }
+ }
+ kill(100)
+ }
+
+}