|
13514
|
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 }
|
