Re: thread pool

From:

Philipp Kraus <philipp.kraus@flashpixx.de>

Newsgroups:

comp.lang.java.programmer

Date:

Thu, 8 Jan 2015 20:42:51 +0100

Message-ID:

<m8mmj7$d3f$1@ariadne.rz.tu-clausthal.de>

This is a multi-part message in MIME format.

----------------9810305661500614159
Content-Type: text/plain; charset=utf-8; format=flowed
Content-Transfer-Encoding: 8bit

Thanks for your answer. I have create a working (as I expected) example:

public class CMainLoop implements Runnable
{
 private ExecutorService m_pool = Executors.newWorkStealingPool();

 private Collection<Callable<Object>> m_tasks = new LinkedList();

 private int m_simulationcount = 0;

 @Override
 public void run()
 {
 while ( !Thread.currentThread().isInterrupted() )
 {

 try
 {

 m_tasks.clear();
 for ( ILayer l_layer :
CSimulation.getInstance().getWorld().values() )
 m_tasks.add( l_layer );
 m_pool.invokeAll( m_tasks );

 m_tasks.clear();
 for ( ILayer l_layer :
CSimulation.getInstance().getWorld().values() )
 if ( l_layer instanceof IMultiLayer )
 {
 for ( Object l_object : ( (IMultiLayer) l_layer ) )
 m_tasks.add( l_object );
 m_pool.invokeAll( m_tasks );
 }

 m_simulationcount++;
 Thread.sleep(
CConfiguration.getInstance().get().ThreadSleepTime );
 }
 catch ( InterruptedException e )
 {
 Thread.currentThread().interrupt();
 return;
 }
 }
 }

 public void stop()
 {
 Thread.currentThread().interrupt();
 }

This code runs very well, at the moment I need a resume / pause
function for the main loop. Can you send me any solution to optimize
my structure?

Thanks

Phil

On 2015-01-08 16:56:06 +0000, Stefan Ram said:

Philipp Kraus <philipp.kraus@flashpixx.de> writes:

I have got a Collection of Collections of Runnables, so the Collections
must be processed in a sequential order, but the Runnable objects can
be processed in parallel.

  You used ??, so??, but I am not sure, whether there is an
  implication here. Possibibly, /in your case/ this must be
  so for additional reasons not given in the sentence above.

My question is, which thread structure can I used for this problem and

  The new stream API supports MapReduce and parallel execution
  of stream filters, and usually should be prefered to
  applications of ??synchronized?? for better exploitation of
  modern multi-core architectures and more safety, maybe
  learning more about this API could be helpful for your?

  I can't really tell how to map your specific problem to the
  new API, though, but when writing parallel code in Java 8 it
  should be the first attempt to try to use this API.

----------------9810305661500614159
Content-Type: text/html; charset=utf-8
Content-Transfer-Encoding: 8bit

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01//EN" "http://www.w3.org/TR/html4/strict.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<meta http-equiv="Content-Style-Type" content="text/css">
<title></title>
<meta name="Generator" content="Cocoa HTML Writer">
<meta name="CocoaVersion" content="1265.21">
<style type="text/css">
p.p1 {margin: 0.0px 0.0px 0.0px 0.0px; line-height: 15.0px; font: 12.0px Helvetica}
p.p2 {margin: 0.0px 0.0px 0.0px 0.0px; line-height: 15.0px; font: 12.0px Helvetica; min-height: 14.0px}
p.p3 {margin: 0.0px 0.0px 0.0px 0.0px; font: 12.0px Menlo}
p.p4 {margin: 0.0px 0.0px 0.0px 12.0px; line-height: 14.0px; font: 12.0px Helvetica; color: #011892}
p.p5 {margin: 0.0px 0.0px 0.0px 24.0px; font: 12.0px Helvetica; color: #008e00}
p.p6 {margin: 0.0px 0.0px 0.0px 12.0px; font: 12.0px Helvetica; color: #011892; min-height: 14.0px}
p.p7 {margin: 0.0px 0.0px 0.0px 12.0px; font: 12.0px Helvetica; color: #011892}
p.p8 {margin: 0.0px 0.0px 0.0px 0.0px; font: 12.0px Helvetica; color: #000000; min-height: 14.0px}
span.s1 {color: #011993}
span.s2 {color: #955fa3}
span.s3 {color: #0433ff}
span.s4 {color: #929000}
</style>
</head>
<body>
Thanks for your answer. I have create a working (as I expected) example:
 
public class CMainLoop implements Runnable 
{ 
?? ?? private ExecutorService m_pool = Executors.newWorkStealingPool(); 
 
?? ?? private Collection<Callable<Object>> m_tasks = new LinkedList(); 
 
?? ?? private int m_simulationcount = 0; 
 
 
?? ?? @Override 
?? ?? public void run() 
?? ?? { 
?? ?? ?? ?? while ( !Thread.currentThread().isInterrupted() ) 
?? ?? ?? ?? { 
 
?? ?? ?? ?? ?? ?? try 
?? ?? ?? ?? ?? ?? { 
 
?? ?? ?? ?? ?? ?? ?? ?? m_tasks.clear(); 
?? ?? ?? ?? ?? ?? ?? ?? for ( ILayer l_layer : CSimulation.getInstance().getWorld().values() ) 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? m_tasks.add( l_layer ); 
?? ?? ?? ?? ?? ?? ?? ?? m_pool.invokeAll( m_tasks ); 
 
 
?? ?? ?? ?? ?? ?? ?? ?? m_tasks.clear(); 
?? ?? ?? ?? ?? ?? ?? ?? for ( ILayer l_layer : CSimulation.getInstance().getWorld().values() ) 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? if ( l_layer instanceof IMultiLayer ) 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? { 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? for ( Object l_object : ( (IMultiLayer) l_layer ) ) 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? m_tasks.add( l_object ); 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? m_pool.invokeAll( m_tasks ); 
?? ?? ?? ?? ?? ?? ?? ?? ?? ?? } 
 
?? ?? ?? ?? ?? ?? ?? ?? m_simulationcount++; 
?? ?? ?? ?? ?? ?? ?? ?? Thread.sleep( CConfiguration.getInstance().get().ThreadSleepTime ); 
?? ?? ?? ?? ?? ?? } 
?? ?? ?? ?? ?? ?? catch ( InterruptedException e ) 
?? ?? ?? ?? ?? ?? { 
?? ?? ?? ?? ?? ?? ?? ?? Thread.currentThread().interrupt(); 
?? ?? ?? ?? ?? ?? ?? ?? return; 
?? ?? ?? ?? ?? ?? } 
?? ?? ?? ?? } 
?? ?? } 
 
 
?? ?? public void stop() 
?? ?? { 
?? ?? ?? ?? Thread.currentThread().interrupt(); 
?? ?? } 

 
This code runs very well, at the moment I need a resume / pause function for the main loop. Can you send me any solution to optimize
my structure?
 
Thanks
 
Phil
 
 
On 2015-01-08 16:56:06 +0000, Stefan Ram said:
 
Philipp Kraus <philipp.kraus@flashpixx.de> writes:
I have got a Collection of Collections of Runnables, so the Collections??
must be processed in a sequential order, but the Runnable objects can??
be processed in parallel.
 
?? You used ??, so??, but I am not sure, whether there is an
?? implication here. Possibibly, /in your case/ this must be
?? so for additional reasons not given in the sentence above.
 
My question is, which thread structure can I used for this problem and??
 
?? The new stream API supports MapReduce and parallel execution
?? of stream filters, and usually should be prefered to
?? applications of ??synchronized?? for better exploitation of
?? modern multi-core architectures and more safety, maybe
?? learning more about this API could be helpful for your?
 
?? I can't really tell how to map your specific problem to the
?? new API, though, but when writing parallel code in Java 8 it
?? should be the first attempt to try to use this API.
 
</body>
</html>
----------------9810305661500614159--