Commitf9f9cf4

Stephane Landelle

committed

Make closeAsynchronously shutdown own thread,closeAsyncHttpClient#458

1 parent321f3c0 commitf9f9cf4Copy full SHA for f9f9cf4

File tree

+14

-10

lines changed

+14

-10

lines changed

Lines changed: 14 additions & 10 deletions

Original file line number	Diff line number	Diff line change
`@@ -375,17 +375,21 @@ public void close() {`
`375`	`375`	`*/`
`376`	`376`	`publicvoidcloseAsynchronously() {`
`377`	`377`	`finalExecutorServicee =Executors.newSingleThreadExecutor();`
`378`		`-e.submit(newRunnable() {`
`379`		`-publicvoidrun() {`
`380`		`-try {`
`381`		`-close();`
`382`		`- }catch (Throwablet) {`
`383`		`-logger.warn("",t);`
`384`		`- }finally {`
`385`		`-e.shutdown();`
	`378`	`+try {`
	`379`	`+e.submit(newRunnable() {`
	`380`	`+publicvoidrun() {`
	`381`	`+try {`
	`382`	`+close();`
	`383`	`+ }catch (Throwablet) {`
	`384`	`+logger.warn("",t);`
	`385`	`+ }finally {`
	`386`	`+e.shutdown();`
	`387`	`+ }`
`386`	`388`	`}`
`387`		`- }`
`388`		`- });`
	`389`	`+ });`
	`390`	`+ }finally {`
	`391`	`+e.shutdown();`
	`392`	`+ }`
`389`	`393`	`}`
`390`	`394`
`391`	`395`	`@Override`

Comments

(0)