blob: 93c2d2261fc7dec7d0184b04d933100153b080db (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
/*
* Created on Friday, May 06 2011 21:02
*/
package com.jogamp.opencl.util.concurrent;
import com.jogamp.opencl.CLCommandQueue;
import com.jogamp.opencl.CLContext;
import com.jogamp.opencl.CLKernel;
import com.jogamp.opencl.CLProgram;
import com.jogamp.opencl.CLResource;
import java.util.Map;
/**
* Superclass for all per-queue contexts as used in {@link CLCommandQueuePool}s.
* A context will usually hold queue (and therefore often device) specific resources used
* in tasks of the same queue.
* <p>
* Possible candidates for those resources can be compiled CLPrograms, CLKernels
* or even pre allocated CLBuffers.
* </p>
* @author Michael Bien
*/
public abstract class CLQueueContext implements CLResource {
public final CLCommandQueue queue;
public CLQueueContext(CLCommandQueue queue) {
this.queue = queue;
}
public CLCommandQueue getQueue() {
return queue;
}
public CLContext getCLContext() {
return queue.getContext();
}
/**
* A simple queue context holding a precompiled program and its kernels.
* @author Michael Bien
*/
public static class CLSingleProgramQueueContext extends CLQueueContext {
public final CLProgram program;
public final Map<String, CLKernel> kernels;
public CLSingleProgramQueueContext(CLCommandQueue queue, CLProgram program) {
super(queue);
this.program = program;
this.kernels = program.createCLKernels();
}
public CLSingleProgramQueueContext(CLCommandQueue queue, String... source) {
this(queue, queue.getContext().createProgram(source).build());
}
public Map<String, CLKernel> getKernels() {
return kernels;
}
public CLKernel getKernel(String name) {
return kernels.get(name);
}
public CLProgram getProgram() {
return program;
}
@Override
public void release() {
synchronized(program) {
if(!program.isReleased()) {
program.release();
}
}
}
@Override
public boolean isReleased() {
return program.isReleased();
}
}
}
|
