multithreading - Java: How to implement a portlistener that doesn't block the rest of the program -

-

i have main class in define java fx scene , stage, , maincontroller in create database connection , start portlistener. 3 different parts (views, db connection , port listener`) function when tested separately, when uncomment parts can test program in full working, doesn't work.

public class main extends application { maincontroller maincontroller;  @override public void start(stage primarystage) {     borderpane root = new borderpane();     scene scene = new scene(root, 1100, 690);      root.settop(setupmenubar());     root.setcenter(setupcenter());     root.setbottom(setupstatusbar());      scene.getstylesheets().add(getclass().getresource("application.css").toexternalform());     primarystage.setscene(scene);      maincontroller = new maincontroller();     maincontroller.initcontroller(primarystage);      primarystage.show(); }

the problem never primarystage.show(); of main program because portlistener sits , waits incoming messages seems me there's 1 thread running. (i thought java multi-threaded default)

the portlistener should wait incoming messages, shouldn't block main program functioning. i've changed portlistener implement runnable, read somewhere runnable's run() method should called newly created thread's start() method in class.

now there's problem, i've created startlistening function in portlistener has 2 parameters, portnumber listen to, , maincontroller instance, portlistener can call function in maincontroller once there incoming message. maincontroller has database connection , variables port number, being class comes together.

the portlistener:

public class portlistener implements runnable {     boolean stayconnected = true;     maincontroller maincontroller;     serversocket serversocket;     socket clientsocket = null;      public void startlistening(int portnumber, maincontroller controller) throws ioexception {         maincontroller = controller;         try {             serversocket = new serversocket(portnumber);             serversocket.setreuseaddress(true);         }          catch (ioexception e) {             system.err.println("could not start listener on port: " + portnumber);             return;         }          while(stayconnected) {             run();         }     }      public void run() {         try {             clientsocket = serversocket.accept();             system.out.println("connection established");              bufferedreader in = new bufferedreader(new inputstreamreader(clientsocket.getinputstream()));             string inputline;              while ((inputline = in.readline()) != null) {                 // todo: handle incoming message calling maincontroller                 system.out.println("line incoming: " + inputline);             }             in.close();              clientsocket.close();             serversocket.close();         } catch (ioexception e) {             system.err.println("portlistener run() failed: " + e.getmessage());         }     }      public void stoplistening() {         stayconnected = false;     } }

i'm missing trivial, there many skilled programmers here, i'd rather ask i'm missing instead of trying hour (or two).


Comments

Post a Comment

Popular posts from this blog

c++ - Linked List error when inserting for the last time -

-
so have part of code here this loop 5 times (max = 5) insert word link list. for ( int = 0 ; < max ; i++ ) { string alphabet = g->returnalphabets(); l[i]->addwords(alphabet[i]); } and have insert word part here string line; fstream myfile ("words.txt"); while (!myfile.eof()) { getline(myfile,line); if ( alphabet == line[0] ) { listnode *newnode = new listnode; if ( head == null ) { newnode->item = alphabet; newnode->next = null; head = newnode; } else { newnode->item = line; prev = cur; prev->next = newnode; } cur = newnode; } } myfile.close(); my problem gives me error on last loop. meaning on max = 4, insert node. rest of loop fine. when decrease max 4 meaning loop 4 times, program error-free when program loops 5 times gives error. anyone can poin...
Read more

java - activate/deactivate sonar maven plugin by profile? -

-
i use sonar plugin executes if activated in maven profile. sonar runs on every compile. the problem build fail other team members not have sonar application installed locally. pom.xml checked in team members same copy including sonar configuration, don't want them modify purpose of disabling sonar (they might inadvertently check modified copy in). please advise how configure maven (.m2/settings.xml) and/or pom.xml sonar feature can enabled/disabled local profile. here sonar configuration in each project's pom.xml: <plugin> <groupid>org.codehaus.mojo</groupid> <artifactid>sonar-maven-plugin</artifactid> <version>1.0</version> <executions> <execution> <id>make-sonar</id> <phase>compile</phase> <goals> <goal>sonar</goal> </goals> </execution> </executions> ...
Read more

tsql - Pivot with Temp Table (definition for column must include data type) -- SQL Server 2008 -

-
the following returning 2 errors: 'the definition column '0.63' must include data type.' 'the select list insert statement contains fewer items insert list. number of select values must match number of insert columns.' i understand need assign data type columns being inserted temp table don't quite understand how dynamic code however. if explanation on how @cols variable code working , specific issue. fldpk data type int , pivot fields i.e. @cols, float data type. declare @cols nvarchar(max), @query nvarchar(max); select @cols = stuff((select distinct ',' + quotename(fldci) fn_qryt_1() xml path(''), type ).value('.', 'nvarchar(max)') ,1,1,'') set @query = 'select fldpk, ' + @cols + ' ( select fldpk ,fldni ...
Read more