Mercurial > hg > graal-compiler

comparison graal/com.oracle.truffle.ruby.runtime/src/com/oracle/truffle/ruby/runtime/subsystems/FiberManager.java @ 13514:0fbee3eb71f0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Ruby: import project.
author Chris Seaton <chris.seaton@oracle.com>
date Mon, 06 Jan 2014 17:12:09 +0000
parents
children
comparison
equal deleted inserted replaced
13513:64a23ce736a0 13514:0fbee3eb71f0
1 /*
2 * Copyright (c) 2013 Oracle and/or its affiliates. All rights reserved. This
3 * code is released under a tri EPL/GPL/LGPL license. You can use it,
4 * redistribute it and/or modify it under the terms of the:
5 *
6 * Eclipse Public License version 1.0
7 * GNU General Public License version 2
8 * GNU Lesser General Public License version 2.1
9 */
10 package com.oracle.truffle.ruby.runtime.subsystems;
11
12 import java.util.*;
13 import java.util.concurrent.*;
14
15 import com.oracle.truffle.ruby.runtime.*;
16 import com.oracle.truffle.ruby.runtime.core.*;
17
18 /**
19 * Manages Ruby {@code Fiber} objects.
20 */
21 public class FiberManager {
22
23 private final RubyFiber rootFiber;
24 private RubyFiber currentFiber;
25
26 private final Set<RubyFiber> runningFibers = Collections.newSetFromMap(new ConcurrentHashMap<RubyFiber, Boolean>());
27
28 public FiberManager(RubyContext context) {
29 rootFiber = new RubyFiber(context.getCoreLibrary().getFiberClass(), this, context.getThreadManager());
30 currentFiber = rootFiber;
31 }
32
33 public RubyFiber getCurrentFiber() {
34 return currentFiber;
35 }
36
37 public void setCurrentFiber(RubyFiber fiber) {
38 currentFiber = fiber;
39 }
40
41 public void registerFiber(RubyFiber fiber) {
42 runningFibers.add(fiber);
43 }
44
45 public void unregisterFiber(RubyFiber fiber) {
46 runningFibers.remove(fiber);
47 }
48
49 public void shutdown() {
50 for (RubyFiber fiber : runningFibers) {
51 fiber.shutdown();
52 }
53 }
54
55 }