質問
私を利用することにしたのだろう先物取引は初めて。いるスマートキャンセルすることができる仕事ではないものとして期待される。以下の例では、最初の仕事は解除されてしまいます。その他は完了です。い誤解され、利用先物取引差入証拠金先物取?
public class ThreadExample
{
public static void main(String[] args) throws InterruptedException, ExecutionException
{
int processors = Runtime.getRuntime().availableProcessors();
System.out.println("Processors: " + processors);
ExecutorService es = Executors.newFixedThreadPool(processors);
int nowork = 10;
Future<Integer>[] workres = new Future[nowork];
for(int i = 0; i < nowork; i++)
{
workres[i] = es.submit(new SomeWork(i));
}
for(int i = 0; i < nowork; i++)
{
if(i % 2 == 0)
{
System.out.println("Cancel");
workres[i].cancel(true);
}
if(workres[i].isCancelled())
{
System.out.println(workres[i] + " is cancelled");
}
else
{
System.out.println(workres[i].get());
}
}
es.shutdown();
}
}
class SomeWork implements Callable<Integer>
{
private int v;
public SomeWork(int v)
{
this.v = v;
}
@Override
public Integer call() throws Exception
{
TimeUnit.SECONDS.sleep(5);
System.out.println(v + " done at " + (new Date()));
return v;
}
}
出力:
Processors: 4
Cancel
java.util.concurrent.FutureTask@10d448 is cancelled
4 done at Wed May 12 17:47:05 CEST 2010
2 done at Wed May 12 17:47:05 CEST 2010
1 done at Wed May 12 17:47:05 CEST 2010
3 done at Wed May 12 17:47:05 CEST 2010
1
Cancel
2
3
Cancel
4
5 done at Wed May 12 17:47:10 CEST 2010
7 done at Wed May 12 17:47:10 CEST 2010
8 done at Wed May 12 17:47:10 CEST 2010
6 done at Wed May 12 17:47:10 CEST 2010
5
Cancel
6
7
Cancel
8
9 done at Wed May 12 17:47:15 CEST 2010
9
解決
問題は、キャンセルのループがどのブロックあなたget()
ループ、と重なっていることです。私は、あなたは、あなたが2つのループを持ってしたくないと思いますか?一の偶数ジョブをキャンセルループ、および第2のループものはキャンセルされたものではない、そしてそれに応じget()
れるチェックこと。
workres[2]
をキャンセルする機会があった、それはチェックしget()
からworkres[1]
を求め前にそれが、今書かれています。 この方法
だから私は、あなたが3つの段階が必要だと思う。
1. The `submit()` loop
2. The selective `cancel()` loop
3. The selective `get()` loop (which blocks)
他のヒント
の Future#cancel()
ま終わらない/割り込みの 実行されて います。でのみを取り消しに走ります。
更新:polygenelubricants釘付けの減少(+1):こちらは改善しコード:
int processors = Runtime.getRuntime().availableProcessors();
System.out.println("Processors: " + processors);
ExecutorService es = Executors.newFixedThreadPool(processors);
int nowork = 10;
Future<Integer>[] workers = new Future[nowork];
for (int i = 0; i < nowork; i++) {
final int ii = i;
workers[i] = es.submit(new Callable<Integer>() {
public Integer call() throws Exception {
return ii;
}
});
}
for (int i = 0; i < nowork; i++) {
if (i % 2 == 0) {
System.out.println("Cancel worker " + i);
workers[i].cancel(true);
}
}
for (int i = 0; i < nowork; i++) {
if (workers[i].isCancelled()) {
System.out.println("Worker " + i + " is cancelled");
} else {
System.out.println("Worker " + i + " returned: " + workers[i].get());
}
}
es.shutdown();
結果:
Processors: 2 Cancel worker 0 Cancel worker 2 Cancel worker 4 Cancel worker 6 Cancel worker 8 Worker 0 is cancelled Worker 1 returned: 1 Worker 2 is cancelled Worker 3 returned: 3 Worker 4 is cancelled Worker 5 returned: 5 Worker 6 is cancelled Worker 7 returned: 7 Worker 8 is cancelled Worker 9 returned: 9
(この workers
, ない workres
).
所属していません StackOverflow