Mercurial > hg > truffle

comparison graal/com.oracle.max.base/src/com/sun/max/util/Deferrable.java @ 3733:e233f5660da4

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added Java files from Maxine project.
author Thomas Wuerthinger <thomas.wuerthinger@oracle.com>
date Sat, 17 Dec 2011 19:59:18 +0100
parents
children bc8527f3071c
comparison
equal deleted inserted replaced
3732:3e2e8b8abdaf 3733:e233f5660da4
1 /*
2 * Copyright (c) 2007, 2011, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
23 package com.sun.max.util;
24
25 import java.util.*;
26
27 /**
28 * Deferred Runnables.
29 *
30 * Creating a Deferrable either causes immediate execution of its 'run()' method
31 * or queues it for deferred execution later on when 'runAll()' is called.
32 */
33 public abstract class Deferrable implements Runnable {
34
35 public Deferrable(Queue queue) {
36 queue.handle(this);
37 }
38
39 @Override
40 public String toString() {
41 return super.toString();
42 }
43
44 public static final class Queue {
45
46 private List<Deferrable> deferrables;
47
48 private Queue() {
49 }
50
51 synchronized void handle(Deferrable deferrable) {
52 if (deferrables != null) {
53 deferrables.add(deferrable);
54 } else {
55 deferrable.run();
56 }
57 }
58
59 public synchronized void deferAll() {
60 deferrables = new LinkedList<Deferrable>();
61 }
62
63 public synchronized void runAll() {
64 while (deferrables != null) {
65 final List<Deferrable> oldDeferrables = this.deferrables;
66 this.deferrables = new LinkedList<Deferrable>();
67 for (Deferrable deferrable : oldDeferrables) {
68 deferrable.run();
69 }
70 if (oldDeferrables.isEmpty()) {
71 this.deferrables = null;
72 }
73 }
74 }
75 }
76
77 public static Queue createRunning() {
78 return new Queue();
79 }
80
81 public static Queue createDeferred() {
82 final Queue queue = new Queue();
83 queue.deferAll();
84 return queue;
85 }
86
87 public abstract static class Block implements Runnable {
88 public Block(Queue queue) {
89 queue.deferAll();
90 run();
91 queue.runAll();
92 }
93 }
94 }