OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:ForkJoinPool
(Results
1 - 15
of
15
) sorted by null
/libcore/luni/src/main/java/java/util/concurrent/
ForkJoinWorkerThread.java
10
* A thread managed by a {@link
ForkJoinPool
}, which executes
17
* custom {@link
ForkJoinPool
.ForkJoinWorkerThreadFactory} to
18
* {@linkplain
ForkJoinPool
#
ForkJoinPool
use it} in a {@code
ForkJoinPool
}.
27
* of class
ForkJoinPool
.
37
final
ForkJoinPool
pool; // the pool this thread works in
38
final
ForkJoinPool
.WorkQueue workQueue; // work-stealing mechanics
46
protected ForkJoinWorkerThread(
ForkJoinPool
pool) {
58
public
ForkJoinPool
getPool()
[
all
...]
ForkJoinTask.java
27
* Abstract base class for tasks that run within a {@link
ForkJoinPool
}.
31
*
ForkJoinPool
, at the price of some usage limitations.
34
* explicitly submitted to a {@link
ForkJoinPool
}, or, if not already
36
*
ForkJoinPool
.commonPool()} via {@link #fork}, {@link #invoke}, or
80
*
ForkJoinPool
.ManagedBlocker} API is used, or the number of possibly
82
*
ForkJoinPool
#getParallelism} level, the pool cannot guarantee that
183
* See the internal documentation of class
ForkJoinPool
for a
186
* to methods in ForkJoinWorkerThread and
ForkJoinPool
.
269
*
ForkJoinPool
. Other variants are directly incorporated into
285
ForkJoinPool
cp = ForkJoinPool.common
[
all
...]
Executors.java
83
return new
ForkJoinPool
85
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
98
return new
ForkJoinPool
100
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
ForkJoinPool.java
26
* A {@code
ForkJoinPool
} provides the entry point for submissions
30
* <p>A {@code
ForkJoinPool
} differs from other kinds of {@link
39
*
ForkJoinPool
}s may also be appropriate for use with event-style
50
*
ForkJoinPool
} may be constructed with a given target parallelism
107
* <li>{@code java.util.concurrent.
ForkJoinPool
.common.parallelism}
109
* <li>{@code java.util.concurrent.
ForkJoinPool
.common.threadFactory}
111
* <li>{@code java.util.concurrent.
ForkJoinPool
.common.exceptionHandler}
132
public class
ForkJoinPool
extends AbstractExecutorService {
470
*
ForkJoinPool
, ForkJoinWorkerThread, and ForkJoinTask. The
472
*
ForkJoinPool
, so are directly accessed. There is little poin
[
all
...]
Phaser.java
71
* also be used by tasks executing in a {@link
ForkJoinPool
},
[
all
...]
ConcurrentHashMap.java
25
import java.util.concurrent.
ForkJoinPool
;
[
all
...]
/libcore/jsr166-tests/src/test/java/jsr166/
ForkJoinPoolTest.java
22
import java.util.concurrent.
ForkJoinPool
;
65
public FailingFJWSubclass(
ForkJoinPool
p) { super(p) ; }
70
implements
ForkJoinPool
.ForkJoinWorkerThreadFactory {
72
public ForkJoinWorkerThread newThread(
ForkJoinPool
p) {
78
static class SubFJP extends
ForkJoinPool
{ // to expose protected
88
static class ManagedLocker implements
ForkJoinPool
.ManagedBlocker {
160
ForkJoinPool
p = new
ForkJoinPool
(1);
162
assertSame(
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
183
new
ForkJoinPool
(-1)
[
all
...]
RecursiveActionTest.java
13
import java.util.concurrent.
ForkJoinPool
;
26
private static
ForkJoinPool
mainPool() {
27
return new
ForkJoinPool
();
30
private static
ForkJoinPool
singletonPool() {
31
return new
ForkJoinPool
(1);
34
private static
ForkJoinPool
asyncSingletonPool() {
35
return new
ForkJoinPool
(1,
36
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
40
private void testInvokeOnPool(
ForkJoinPool
pool, RecursiveAction a) {
326
* join/quietlyJoin of a forked task when not in
ForkJoinPool
[
all
...]
RecursiveTaskTest.java
12
import java.util.concurrent.
ForkJoinPool
;
23
private static
ForkJoinPool
mainPool() {
24
return new
ForkJoinPool
();
27
private static
ForkJoinPool
singletonPool() {
28
return new
ForkJoinPool
(1);
31
private static
ForkJoinPool
asyncSingletonPool() {
32
return new
ForkJoinPool
(1,
33
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
37
private <T> T testInvokeOnPool(
ForkJoinPool
pool, RecursiveTask<T> a) {
543
final
ForkJoinPool
mainPool = mainPool()
[
all
...]
ForkJoinTaskTest.java
11
import java.util.concurrent.
ForkJoinPool
;
29
private static
ForkJoinPool
mainPool() {
30
return new
ForkJoinPool
(mainPoolSize);
33
private static
ForkJoinPool
singletonPool() {
34
return new
ForkJoinPool
(1);
37
private static
ForkJoinPool
asyncSingletonPool() {
38
return new
ForkJoinPool
(1,
39
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
43
private void testInvokeOnPool(
ForkJoinPool
pool, RecursiveAction a) {
698
final
ForkJoinPool
mainPool = mainPool()
[
all
...]
CountedCompleterTest.java
11
import java.util.concurrent.
ForkJoinPool
;
32
private static
ForkJoinPool
mainPool() {
33
return new
ForkJoinPool
(mainPoolSize);
36
private static
ForkJoinPool
singletonPool() {
37
return new
ForkJoinPool
(1);
40
private static
ForkJoinPool
asyncSingletonPool() {
41
return new
ForkJoinPool
(1,
42
ForkJoinPool
.defaultForkJoinWorkerThreadFactory,
46
private void testInvokeOnPool(
ForkJoinPool
pool, ForkJoinTask a) {
918
final
ForkJoinPool
mainPool = mainPool()
[
all
...]
/external/proguard/examples/
scala.pro
56
-keepclassmembernames class scala.concurrent.forkjoin.
ForkJoinPool
{
60
scala.concurrent.forkjoin.
ForkJoinPool
$WaitQueueNode syncStack;
61
scala.concurrent.forkjoin.
ForkJoinPool
$WaitQueueNode spareStack;
/prebuilts/tools/common/proguard/proguard4.7/examples/
scala.pro
56
-keepclassmembernames class scala.concurrent.forkjoin.
ForkJoinPool
{
60
scala.concurrent.forkjoin.
ForkJoinPool
$WaitQueueNode syncStack;
61
scala.concurrent.forkjoin.
ForkJoinPool
$WaitQueueNode spareStack;
/prebuilts/sdk/current/
android.jar
/prebuilts/sdk/system_current/
android.jar
Completed in 602 milliseconds