java中的线程数组

本文关键字：数组 线程 java | 更新日期: 2023-09-27 18:00:23

我需要知道java中的线程数组

  Thread[] TCreate = new Thread[iThreadSize];
        for (int i = 0; i < TCreate.Length; i++)
        {
            TCreate[i] = new Thread(delegate()
                {
                    lst.Add(this.getResult(url));
                });
            TCreate[i].Name = "URL"+i;
            TCreate[i].Start();
        }
        for(int j=0;j<TCreate.Length;j++)
            while (TCreate[j].IsAlive)
            Thread.Sleep(10);

我需要知道如何在java中做到这一点。

MyTestClass qryCompoents=new MyTestClass();
for(int i=0;i<ThreadSize;i++)
        {
            switch(obj.getQueryLevelValue(i))  //Decide according to level
            {
            case 1:
                    qryCompoents.prepareAndProcess_I(obj.getQueryString(i),obj,i);
                    break;
            case 2:
                    qryCompoents.prepareAndProcess_II(obj.getQueryString(i),obj,i);
                    break;
            }               
        }

如果你需要任何细节，请告诉我。

如果我转换这个

    Thread[] TCreate = new Thread[numExpression];
        for(int i=0;i<numExpression;i++)
        {
             TCreate[i] = new Thread(new Runnable() {
                    public void run() {
                        switch(obj.getQueryLevelValue(i))  //Decide according to level
                        {
                        case 1:
                                qryCompoents.prepareAndProcess_I(obj.getQueryString(i),obj,i);
                                break;
                        case 2:
                                qryCompoents.prepareAndProcess_II(obj.getQueryString(i),obj,i);
                                break;
                        }           
                    }
                });
                TCreate[i].setName("URL"+i);
                TCreate[i].start();         
        }
          for (int j = 0; j < TCreate.length; j++)
                while (TCreate[j].isAlive())
                     Thread.sleep(5);

显示错误：无法引用在其他方法中定义的内部类中的非最终变量"obj"

提前感谢

java中的线程数组

它非常模拟。java有一个Runnable接口，而不是Delicates，java有setName方法，而不是C#的Name属性。除此之外，差异很小：

Thread[] TCreate = new Thread[iThreadSize];
for (int i = 0; i < TCreate.length; i++) {
    TCreate[i] = new Thread(new Runnable() {
        public void run() {
            lst.Add(this.getResult(url));
        }
    });
    TCreate[i].setName("URL"+i);
    TCreate[i].start();
}
for (int j = 0; j < TCreate.length; j++)
    while (TCreate[j].isAlive())
         Thread.sleep(10);

至于您的obj变量，我不知道它是什么，您可以尝试声明它为final但请注意，final引用不能更改，但在您的情况下，它可能只是起作用

`final Object obj = ....;`

使用ThreadPool可以执行以下操作。

// only needed if you don't want to reuse the pool.
ExecutorService executor = Executors.newCachedThreadPool();
// ----
List<Future<Result>> results = new ArrayList<Future<Result>>();
for (int i = 0; i < iThreadSize; i++) 
    results.add(executor.submit(new Callable<Result>() {
        public Result call() {
            return getResult(url));
        }
    });
for(Future<Result> future: results)
    lst.add(future.get());
// ----
// only needed if you don't want to reuse the pool.
executor.shutdown();

注意，您也可以使用它来获取组的所有活动线程：

Thread[] activeThreads = new Thread[Thread.activeCount];
Thread.enumerate( activeThreads  );
相关文章：