/* * 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]) { } }