Форум программистов [Powered by Invision Power Board]

Код

    static volatile boolean forceExitFlag = false;

                Thread[] threads = new Thread[2];
                for (final Account account : accounts)
                {
                    Thread aThread = new Thread(new Runnable() {

                        public void run()
                        {
...
                            while (!forceExitFlag)
                            {

                                while (!forceExitFlag && hasNewTask())
                                {
                                    count++;

// do something...
                                    if (!forceExitFlag)
                                    {
                                        try
                                        {
// нужно подождать из-за ограничений...
                                            Thread.sleep(10 * 1000);
                                        } catch (InterruptedException e)
                                        {
...
                                        }
                                    }
                                }
                                forceExitFlag = true;
                            }
                            activeThreads--;
                        }
                    });

                    activeThreads++;
                    threads[activeThreads - 1] = pricesScannerThread;
                    aThread.start();
                }

//                int threadsCount = activeThreads;

                while (activeThreads > 0)
                {
                    Thread.sleep(1000);
                    if (forceExitFlag)
                    {
                        for (Thread t : threads)
                        {
                            if (t != null && !t.isInterrupted())
                            {
                                t.interrupt();
                            }
                        }
                    }
...
                }