Re: thread pool
In article <lqlna0$23fm$1@ariadne.rz.tu-clausthal.de>,
Philipp Kraus <philipp.kraus@flashpixx.de> wrote:
Hello,
I would like to create a thread pool with threads, which are should
stopped by the user.
So I create my pool with
m_pool = Executors.newCachedThreadPool();
for (int i = 0; i < m_barrier.getParties(); i++)
m_pool.submit(new Worker(m_barrier));
my Worker implements Runnable with the run-method
while (!Thread.currentThread().isInterrupted()) {
// do something
}
Within the while-loop I run my barrier and I catch the InterruptedException
I would like to create a thread pool with a number of threads, which
runs until the user
sends a stop signal. At the moment I run m_pool.shutdown() and/or
shutdownNow(), but
which way is the correct Java structure. My target is, that a method
creates all threads
of the pool, each thread runs unlimited time until the user sends a
stop signal.
Thanks a lot
Phil
Executors are used to run a fluctuating number of tasks with some stable
number of threads. It's not meant for the way you're using it. Just
create real Threads (or Runnable for real Threads).
public class ThreadFooCPUIntensive
{
volatile WorkerFoo threads[]= null;
public synchronized void start ()
{
if (threads == null)
{
threads= new WorkerFoo[5];
for (int i= 0; i < threads.length; ++i)
threads[i]= new WorkerFoo();
for (int i= 0; i < threads.length; ++i)
threads[i].start();
}
}
public void stop () throws InterruptedException
{
final Thread origThreads[];
synchronized (this)
{
origThreads= threads;
threads= null;
}
if (origThreads != null)
for (int i= 0; i < origThreads.length; ++i)
origThreads[i].join();
}
class WorkerFoo extends Thread
{
@Override
public void run()
{
final WorkerFoo origThreads[]= threads;
while (origThreads == threads)
{
//CPU intensive stuff
}
}
}
}
--------------- or ------------------------
public class ThreadFooIOIntensive
{
WorkerFoo threads[]= null;
public synchronized void start ()
{
if (threads == null)
{
threads= new WorkerFoo[5];
for (int i= 0; i < threads.length; ++i)
threads[i]= new WorkerFoo();
for (int i= 0; i < threads.length; ++i)
threads[i].start();
}
}
public void stop () throws InterruptedException
{
final Thread origThreads[];
synchronized (this)
{
origThreads = threads;
threads = null;
}
if (origThreads != null)
{
for (int i = 0; i < origThreads.length; ++i)
origThreads[i].interrupt();
for (int i = 0; i < origThreads.length; ++i)
origThreads[i].join();
}
}
class WorkerFoo extends Thread
{
@Override
public void run()
{
try
{
while (true)
{
//IO intensive stuff
}
}
catch (InterruptedIOException e)
{
}
catch (InterruptedException e)
{
}
}
}
}