/*
* This file is part of the X10 project (http://x10-lang.org).
*
* This file is licensed to You under the Eclipse Public License (EPL);
* You may not use this file except in compliance with the License.
* You may obtain a copy of the License at
* http://www.opensource.org/licenses/eclipse-1.0.php
*
* (C) Copyright IBM Corporation 2010.
*/
public class AtomicQueue {
val maxSize = 10;
val q = new Array[Double](1..size, 0);
var first : Int = 0;
var size : Int = 0;
def add(s:Double) {
await(size < maxSize) {
size += 1;
}
}
public static def main(argv:Array[String]) {
}
}