Revision 5269 branches/MULTITHREADING_DEVELOPMENT/libraries/libRemoteServices/src/org/gvsig/remoteClient/taskplanning/retrieving/RetrieveQueue.java
RetrieveQueue.java | ||
---|---|---|
33 | 33 |
new Thread(worker).start(); |
34 | 34 |
} |
35 | 35 |
|
36 |
|
|
37 | 36 |
public IRunnableTask put(IRunnableTask task) { |
38 | 37 |
tasks.add(task); |
39 | 38 |
if (waiting) { |
... | ... | |
105 | 104 |
} |
106 | 105 |
} |
107 | 106 |
} |
108 |
|
|
109 |
|
|
110 |
|
|
111 |
|
|
112 |
protected URLRetrieveTask getURLPreviousRequest(URLRequest request) { |
|
113 |
// Is the one currently running? |
|
114 |
/*URLRetrieveTask aux = (URLRetrieveTask) worker.r; |
|
115 |
if (request.equals(aux.getRequest())) { |
|
116 |
return aux; |
|
117 |
}*/ |
|
118 |
// Is one of those in the queue? |
|
119 |
for (int i = 0; i < tasks.size(); i++) { |
|
120 |
URLRetrieveTask task = (URLRetrieveTask) tasks.get(i); |
|
121 |
URLRequest aWorkingRequest = task.getRequest(); |
|
122 |
if (aWorkingRequest.equals(request)) { |
|
123 |
return task; |
|
124 |
} |
|
125 |
} |
|
126 |
return null; |
|
127 |
} |
|
128 | 107 |
} |
Also available in: Unified diff