Multi Threading et FaceContext

prenez l'exemple du push de richfaces :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
	  xmlns:f="http://java.sun.com/jsf/core"
      xmlns:h="http://java.sun.com/jsf/html"
      xmlns:ui="http://java.sun.com/jsf/facelets"
      xmlns:a4j="http://richfaces.org/a4j"
      xmlns:c="http://java.sun.com/jsp/jstl/core"
      >
      <body>
	<f:view>
	<a4j:push reRender="msg" eventProducer="#{messageBean.addListener}" interval="3000"/>
 
	<h:dataTable  id="msg" value="#{messageBean.messages}" var="msg">
	    <f:facet name="header"><h2>Messags : </h2></f:facet>
	    <h:column>
	      Message :
	    </h:column>
	    <h:column>
	    <h:outputText value="#{msg}"></h:outputText>
	    </h:column>
	</h:dataTable>
	<h:form>
	<a4j:status startText="Request started" stopText="stop."></a4j:status>
	</h:form>
	<a4j:log hotkey="M"></a4j:log>
	</f:view>
	</body>
</html>

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package com.sungard.irims;
 
import java.util.ArrayList;
import java.util.Date;
import java.util.EventListener;
import java.util.EventObject;
import java.util.List;
 
import javax.faces.context.FacesContext;
 
import org.ajax4jsf.event.PushEventListener;
 
public class MessageBean implements Runnable {
 
	private String result;
 
	private boolean running = true;
 
	private PushEventListener listener;
 
	private List messages = new ArrayList(10);
 
	private int counter = 0;
 
	public MessageBean() {
		// TODO Auto-generated constructor stub
	}
 
	/**
         * @return the result
         */
	public String getResult() {
		return result;
	}
 
	/**
         * @param result
         *            the result to set
         */
	public void setResult(String result) {
		this.result = result;
	}
 
	public void addListener(EventListener listener) {
		synchronized (listener) {
			if (this.listener != listener) {
				this.listener = (PushEventListener) listener;
				Thread th = new Thread(this);
				th.start();
 
			}
		}
	}
 
	public void run() {
		try {
			while (isRunning()) {
				Thread.sleep(10000);
				Date current = new Date(System.currentTimeMillis());
				if (messages.size() >= 10) {
					messages.remove(0);
				}
				messages.add(messages.size(), String.valueOf(counter++)
						+ " at " + current.toString());
				System.out.println("event occurs");
				if (FacesContext.getCurrentInstance()==null){
					System.out.println("Pas de Faces Context");	
				}
				synchronized (listener) {
					listener.onEvent(new EventObject(this));
				}
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
 
	}
 
	/**
         * @return the running
         */
	public synchronized boolean isRunning() {
		return running;
	}
 
	/**
         * @param running
         *            the running to set
         */
	public synchronized void setRunning(boolean running) {
		this.running = running;
	}
 
	/**
         * @return the messages
         */
	public List getMessages() {
		return messages;
	}
 
	/**
         * @param messages
         *            the messages to set
         */
	public void setMessages(List messages) {
		this.messages = messages;
	}
 
}